#include <iostream> #include "rx-includes.hpp" class Man { public: Man(); ~Man(); void hello(); private: int age; std::string name; }; template <typename T> class AbstBase { public: T hoge; }; class FuncClass { public: FuncClass() : connectStateOb(std::shared_p</typename></iostream>…

さらに簡単な例 #include <rxcpp/rx.hpp> rxcpp::observable<std::string> twice(std::string word) { return rxcpp::observable<>::just(word + word); } rxcpp::observable<int> length(std::string word) { int l = (int)word.length(); return rxcpp::observable<>::just(l); } rxcpp::ob</int></std::string></rxcpp/rx.hpp>…

一番簡単な使い方 rxcpp::observable<int> obs = rxcpp::observable<>::create<int> ( [=](rxcpp::subscriber<int> s) { s.on_next(100); s.on_next(200); s.on_next(300); s.on_completed(); } ); auto x = obs.flat_map([=](int x) { return rxcpp::observable<>::just(x </int></int></int>…