/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
D | rx-subscriber.hpp | 224 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 …]
|
D | rx-notification.hpp | 137 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/ |
D | observer.cpp | 19 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/ |
D | replay.cpp | 27 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 …]
|
D | publish.cpp | 164 auto res = w.make_subscriber<int>(); 279 auto res = w.make_subscriber<int>(); 378 auto res = w.make_subscriber<int>();
|
D | lift.cpp | 52 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/ |
D | rx-subscribe.hpp | 88 -> 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()
|
D | rx-window_toggle.hpp | 135 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()
|
D | rx-switch_on_next.hpp | 127 auto sink = make_subscriber<collection_type>( in on_subscribe() 150 auto sinkInner = make_subscriber<collection_value_type>( in on_subscribe()
|
D | rx-merge.hpp | 147 auto sink = make_subscriber<source_value_type>( in on_subscribe() 168 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
|
D | rx-merge_delay_error.hpp | 141 auto sink = make_subscriber<source_value_type>( in on_subscribe() 162 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
|
D | rx-amb.hpp | 143 auto sink = make_subscriber<source_value_type>( in on_subscribe() 170 auto sinkInner = make_subscriber<value_type>( in on_subscribe()
|
D | rx-concat.hpp | 138 auto sinkInner = make_subscriber<value_type>( in on_subscribe() 198 auto sink = make_subscriber<collection_type>( in on_subscribe()
|
D | rx-take_until.hpp | 138 auto sinkTrigger = make_subscriber<typename trigger_source_type::value_type>( in on_subscribe() 169 auto sinkSource = make_subscriber<T>( in on_subscribe()
|
D | rx-ignore_elements.hpp | 68 return make_subscriber<value_type>(d, this_type(d)); in make()
|
D | rx-distinct.hpp | 72 return make_subscriber<value_type>(d, this_type(d)); in make()
|
D | rx-skip_while.hpp | 86 return make_subscriber<value_type>(d, this_type(d, std::move(t))); in make()
|
D | rx-finally.hpp | 88 return make_subscriber<value_type>(cs, this_type(d)); in make()
|
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
D | subject.cpp | 259 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/ |
D | create.cpp | 25 auto subscriber = rxcpp::make_subscriber<int>( 50 auto subscriber = rxcpp::make_subscriber<int>(
|
D | subscribe.cpp | 8 auto subscriber = rxcpp::make_subscriber<int>( 18 auto subscriber = rxcpp::make_subscriber<int>(
|
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
D | rx-test.hpp | 122 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/ |
D | rx-synchronize.hpp | 137 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()
|
D | rx-behavior.hpp | 53 …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/ |
D | create.cpp | 57 auto sn = rx::make_subscriber<int>(so, in __anon44bf292c0302()
|