Searched refs:get_observable (Results 1 – 13 of 13) sorted by relevance
327 auto source = sub.get_observable(); in __anon2b91aec50d02()345 sub.get_observable().subscribe(403 sub.get_observable() in __anon2b91aec51402()415 sub.get_observable()498 s.get_observable().subscribe(results1); record(300);}); in __anon2b91aec51f02()500 s.get_observable().subscribe(results2); record(400);}); in __anon2b91aec52002()502 s.get_observable().subscribe(results3); record(900);}); in __anon2b91aec52102()605 s.get_observable().subscribe(results1);}); in __anon2b91aec52902()607 s.get_observable().subscribe(results2);}); in __anon2b91aec52a02()609 s.get_observable().subscribe(results3);}); in __anon2b91aec52b02()[all …]
87 dest.on_next(subj[0].get_observable().as_dynamic()); in window_observer()102 dest.on_next(subj[subj.size() - 1].get_observable().as_dynamic()); in on_next()
61 state->subject_value.get_observable().subscribe(std::forward<Subscriber>(o)); in on_subscribe()
151 state->dest.on_next(state->subj.get_observable().as_dynamic()); in release_window()
143 localState->dest.on_next(it->get_observable().as_dynamic()); in window_toggle_observer()
159 …calState->dest.on_next(localState->subj[localState->subj.size() - 1].get_observable().as_dynamic()… in window_with_time_observer()
172 subject.get_observable().subscribe(std::forward<Subscriber>(o)); in on_subscribe()
54 struct get_observable struct in rxcpp::coordinator79 is_observable<T>::value, get_observable<T>, typename std::conditional<94 -> typename get_observable<Observable>::type { in in()
92 observable<T> get_observable() const { in get_observable() function in rxcpp::subjects::behavior
170 observable<T> get_observable() const { in get_observable() function in rxcpp::subjects::replay
182 observable<T> get_observable() const { in get_observable() function in rxcpp::subjects::synchronize
265 observable<T> get_observable() const { in get_observable() function in rxcpp::subjects::subject
81 return subject.get_observable(); in messages()