Searched defs:connect_forever (Results 1 – 2 of 2) sorted by relevance
35 struct connect_forever : public operator_base<T> struct37 typedef rxu::decay_t<ConnectableObservable> source_type;39 source_type source;41 explicit connect_forever(source_type o) in connect_forever() argument48 void on_subscribe(Subscriber&& o) const { in on_subscribe()58 auto connect_forever(AN&&... an) in connect_forever() function
179 auto connect_forever(AN... an) const in connect_forever() function in rxcpp::connectable_observable