Home
last modified time | relevance | path

Searched refs:make_subscriber (Results 1 – 25 of 64) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscriber.hpp224 auto make_subscriber( in make_subscriber() function
234 auto make_subscriber() in make_subscriber() function
243 auto make_subscriber( in make_subscriber() function
249 auto make_subscriber(const Observer& o) in make_subscriber() function
257 auto make_subscriber(const Observer& o) in make_subscriber() function
267 auto make_subscriber(const OnNext& on) in make_subscriber() function
275 auto make_subscriber(const OnNext& on, const OnError& oe) in make_subscriber() function
284 auto make_subscriber(const OnNext& on, const OnCompleted& oc) in make_subscriber() function
293 auto make_subscriber(const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber() function
307 auto make_subscriber(const composite_subscription& cs) in make_subscriber() function
[all …]
Drx-notification.hpp137 other->accept(make_subscriber<T>(make_observer_dynamic<T>([this, &result](T v) { in equals()
162 … other->accept(make_subscriber<T>(make_observer_dynamic<T>([](T){}, [&result](rxu::error_ptr){ in equals()
181 other->accept(make_subscriber<T>(make_observer_dynamic<T>([](T){}, [&result](){ in equals()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dobserver.cpp19 auto scrbResult = rx::make_subscriber<int>(next, error, completed);
20 auto scrbdup = rx::make_subscriber<int>(scrbResult);
21 auto scrbop = rx::make_subscriber<int>(scrbResult, next, error, completed);
22 auto scrbsharelifetime = rx::make_subscriber<int>(scrbResult, scrbop.get_observer());
23 … auto scrbuniquelifetime = rx::make_subscriber<int>(scrbResult, rx::composite_subscription());
26 auto scrb = rx::make_subscriber<int>(emptyNext);
107 auto dob = rx::make_subscriber<int>(rx::make_observer_dynamic<int>(next, error, completed));
108 auto so = rx::make_subscriber<int>(next, error, completed);
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dreplay.cpp27 auto res = w.make_subscriber<int>();
140 auto res = w.make_subscriber<int>();
261 auto res1 = w.make_subscriber<int>();
265 auto res2 = w.make_subscriber<int>();
269 auto res3 = w.make_subscriber<int>();
391 auto res1 = w.make_subscriber<int>();
395 auto res2 = w.make_subscriber<int>();
399 auto res3 = w.make_subscriber<int>();
510 auto res1 = w.make_subscriber<int>();
514 auto res2 = w.make_subscriber<int>();
[all …]
Dpublish.cpp164 auto res = w.make_subscriber<int>();
279 auto res = w.make_subscriber<int>();
378 auto res = w.make_subscriber<int>();
Dlift.cpp52 return rx::make_subscriber<value_type>(d, observer_type(this_type(d, t))); in make()
246 return rx::make_subscriber<int>( in __anon3192a8220602()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe.hpp88 -> detail::subscribe_factory<decltype (make_subscriber<T>(std::forward<ArgN>(an)...))> { in subscribe()
89 return detail::subscribe_factory<decltype (make_subscriber<T>(std::forward<ArgN>(an)...))> in subscribe()
90 (make_subscriber<T>(std::forward<ArgN>(an)...)); in subscribe()
Drx-window_toggle.hpp135 auto sink = make_subscriber<openings_value_type>( in window_toggle_observer()
170 auto sink = make_subscriber<closings_value_type>( in window_toggle_observer()
259 …return make_subscriber<T>(cs, observer_type(this_type(cs, std::move(d), std::move(v), std::move(co… in make()
Drx-switch_on_next.hpp127 auto sink = make_subscriber<collection_type>( in on_subscribe()
150 auto sinkInner = make_subscriber<collection_value_type>( in on_subscribe()
Drx-merge.hpp147 auto sink = make_subscriber<source_value_type>( in on_subscribe()
168 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
Drx-merge_delay_error.hpp141 auto sink = make_subscriber<source_value_type>( in on_subscribe()
162 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
Drx-amb.hpp143 auto sink = make_subscriber<source_value_type>( in on_subscribe()
170 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
Drx-concat.hpp138 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
198 auto sink = make_subscriber<collection_type>( in on_subscribe()
Drx-take_until.hpp138 auto sinkTrigger = make_subscriber<typename trigger_source_type::value_type>( in on_subscribe()
169 auto sinkSource = make_subscriber<T>( in on_subscribe()
Drx-ignore_elements.hpp68 return make_subscriber<value_type>(d, this_type(d)); in make()
Drx-distinct.hpp72 return make_subscriber<value_type>(d, this_type(d)); in make()
Drx-skip_while.hpp86 return make_subscriber<value_type>(d, this_type(d, std::move(t))); in make()
Drx-finally.hpp88 return make_subscriber<value_type>(cs, this_type(d)); in make()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp259 auto o = rx::make_subscriber<int>(
335 rx::make_subscriber<int>( in __anon0164c1a70d02()
472 auto results1 = w.make_subscriber<int>();
474 auto results2 = w.make_subscriber<int>();
476 auto results3 = w.make_subscriber<int>();
587 auto results1 = w.make_subscriber<int>();
589 auto results2 = w.make_subscriber<int>();
591 auto results3 = w.make_subscriber<int>();
680 auto results1 = w.make_subscriber<int>();
682 auto results2 = w.make_subscriber<int>();
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dcreate.cpp25 auto subscriber = rxcpp::make_subscriber<int>(
50 auto subscriber = rxcpp::make_subscriber<int>(
Dsubscribe.cpp8 auto subscriber = rxcpp::make_subscriber<int>(
18 auto subscriber = rxcpp::make_subscriber<int>(
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-test.hpp122 subscriber<T, rxt::testable_observer<T>> make_subscriber() const;
188 subscriber<T, rxt::testable_observer<T>> test_type::test_type_worker::make_subscriber() const in make_subscriber() function in rxcpp::schedulers::detail::test_type::test_type_worker
195 return rxcpp::make_subscriber<T>(rxt::testable_observer<T>(ts, make_observer_dynamic<T>( in make_subscriber()
483 auto state = std::make_shared<state_type>(this->make_subscriber<T>()); in start()
548 subscriber<T, rxt::testable_observer<T>> make_subscriber() const { in make_subscriber() function in rxcpp::schedulers::test::test_worker
549 return tester->make_subscriber<T>(); in make_subscriber()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp137 auto o = make_subscriber<T>(dl, make_observer_dynamic<T>( *static_cast<base_type*>(this) )); in synchronize_observer()
146 …return make_subscriber<T>(this->get_id(), state->lifetime, observer<T, detail::synchronize_observe… in get_subscriber()
Drx-behavior.hpp53 …return make_subscriber<T>(this->get_id(), this->get_subscription(), observer<T, detail::behavior_o… in get_subscriber()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dcreate.cpp57 auto sn = rx::make_subscriber<int>(so, in __anon44bf292c0302()

123