D | rx-observable.hpp | 118 static observable_type make(const Default&, AN&&... an) { in make() 119 return observable_type(type(std::forward<AN>(an)...)); in make() 140 static observable_type make(AN&&... an) { in make() 141 return observable_type(type(std::forward<AN>(an)...)); in make() 172 static auto blocking_subscribe(const Obsvbl& source, bool do_rethrow, ArgN&&... an) in blocking_subscribe() argument 179 auto dest = make_subscriber<T>(std::forward<ArgN>(an)...); in blocking_subscribe() 238 auto subscribe(ArgN&&... an) const in subscribe() 240 return blocking_subscribe(source, false, std::forward<ArgN>(an)...); in subscribe() 263 auto subscribe_with_rethrow(ArgN&&... an) const in subscribe_with_rethrow() 265 return blocking_subscribe(source, true, std::forward<ArgN>(an)...); in subscribe_with_rethrow() [all …]
|