| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | observer.cpp | 120 REQUIRE(dob.is_subscribed());
123 REQUIRE(so.is_subscribed());
137 REQUIRE(dob.is_subscribed());
141 REQUIRE(so.is_subscribed());
155 REQUIRE(!dob.is_subscribed());
159 REQUIRE(!so.is_subscribed());
173 REQUIRE(!dob.is_subscribed());
177 REQUIRE(!so.is_subscribed());
|
| D | subscription.cpp | 373 REQUIRE(s.is_subscribed());
382 REQUIRE(!s.is_subscribed());
387 REQUIRE(!s.is_subscribed());
407 REQUIRE(!s.is_subscribed());
413 REQUIRE(!s.is_subscribed());
418 REQUIRE(!s.is_subscribed());
433 REQUIRE(s.is_subscribed());
442 REQUIRE(!s.is_subscribed());
447 REQUIRE(!s.is_subscribed());
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-newthread.hpp | 101 return !keepAlive->lifetime.is_subscribed() || !keepAlive->q.empty(); in new_worker()
104 if (!keepAlive->lifetime.is_subscribed()) { in new_worker()
108 if (!peek.what.is_subscribed()) { in new_worker()
134 if (scbl.is_subscribed()) { in schedule()
|
| D | rx-currentthread.hpp | 85 if (!item.what.is_subscribed()) { in push()
187 if (!scbl.is_subscribed()) { in schedule()
209 if (scbl.is_subscribed()) { in schedule()
226 if (what.is_subscribed()) { in schedule()
|
| D | rx-virtualtime.hpp | 79 if (next.what.is_subscribed()) { in start()
112 if (!next.what.is_subscribed()) { in advance_to()
215 if (scbl.is_subscribed()) { in schedule_absolute()
|
| D | rx-immediate.hpp | 38 if (scbl.is_subscribed()) { in schedule()
47 if (scbl.is_subscribed()) { in schedule()
|
| D | rx-runloop.hpp | 78 if (scbl.is_subscribed()) { in schedule()
180 if (!peek.what.is_subscribed()) { in dispatch()
|
| D | rx-test.hpp | 253 if (o.is_subscribed()) { in on_subscribe()
308 if (o.is_subscribed()) { in hot_observable()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 71 return o.is_subscribed(); in retain()
138 if (o.is_subscribed()) { in add()
189 if (o.is_subscribed()) { in on_next()
205 if (o.is_subscribed()) { in on_error()
223 if (o.is_subscribed()) { in on_completed()
|
| D | rx-synchronize.hpp | 61 if (!destination.is_subscribed()) { in ensure_processing()
106 if (lifetime.is_subscribed()) { in on_next()
114 if (lifetime.is_subscribed()) { in on_error()
122 if (lifetime.is_subscribed()) { in on_completed()
|
| D | rx-behavior.hpp | 95 if (keepAlive.get_subscription().is_subscribed()) { in get_observable()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 48 bool is_subscribed() {return issubscribed;} in is_subscribed() function in syncwithvoid::sync_subscriber
68 for (int i = 0; i < onnextcalls && scbr.is_subscribed(); i++) {
111 bool is_subscribed() {return issubscribed;} in is_subscribed() function in asyncwithready::async_subscriber
156 for (; i < onnextcalls && scbr.is_subscribed(); i++) { in __anon0164c1a70402()
186 bool is_subscribed() {return issubscribed;} in is_subscribed() function in asyncwithfuture::async_subscriber
207 for (int i = 0; i < onnextcalls && scbr.is_subscribed(); i++) {
262 for (int i = 0; i < onnextcalls && o.is_subscribed(); i++) {
328 while(o.is_subscribed()) { in __anon0164c1a70d02()
353 for (int i = 0; i < onnextcalls && o.is_subscribed(); i++) {
400 while(o.is_subscribed()) { in __anon0164c1a71402()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-observe_on.hpp | 122 if (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty()) { in ensure_processing()
132 if (drain_queue.empty() || !destination.is_subscribed()) { in ensure_processing()
134 if (!destination.is_subscribed() || in ensure_processing()
135 … (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty())) { in ensure_processing()
152 if (lifetime.is_subscribed()) break; in ensure_processing()
|
| D | rx-concat.hpp | 156 } else if (!state->sourceLifetime.is_subscribed()) { in on_subscribe()
203 if (state->collectionLifetime.is_subscribed()) { in on_subscribe()
215 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()
|
| D | rx-concat_map.hpp | 196 } else if (!state->sourceLifetime.is_subscribed()) { in on_subscribe()
242 if (state->collectionLifetime.is_subscribed()) { in on_subscribe()
254 … if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) { in on_subscribe()
|
| D | rx-group_by.hpp | 124 if (!state->source_lifetime.is_subscribed()) { in stopsource()
209 if (!dest.is_subscribed()) { in on_next()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-scheduler.hpp | 234 inline bool is_subscribed() const { in is_subscribed() function in rxcpp::schedulers::worker
235 return lifetime.is_subscribed(); in is_subscribed()
592 inline bool is_subscribed() const { in is_subscribed() function in rxcpp::schedulers::schedulable
593 return lifetime.is_subscribed(); in is_subscribed()
620 if (is_subscribed()) { in schedule()
626 if (is_subscribed()) { in schedule()
632 if (is_subscribed()) { in schedule()
641 if (!is_subscribed()) { in operator ()()
710 while (s.is_subscribed()) { in operator ()()
|
| D | rx-subscription.hpp | 172 bool is_subscribed() const { in is_subscribed() function in rxcpp::subscription
287 } else if (s.is_subscribed()) { in add()
503 using subscription::is_subscribed;
585 bool is_subscribed() const { in is_subscribed() function in rxcpp::resource
586 return lifetime.is_subscribed(); in is_subscribed()
|
| D | rx-coroutine.hpp | 61 if (!state->lifetime.is_subscribed()) {return false;} in await_suspend()
94 return !!state && !rhs.state && !state->lifetime.is_subscribed(); in operator ==()
|
| D | rx-subscriber.hpp | 177 if (!is_subscribed()) { in on_next()
184 if (!is_subscribed()) { in on_error()
191 if (!is_subscribed()) { in on_completed()
200 bool is_subscribed() const { in is_subscribed() function in rxcpp::subscriber
201 return lifetime.is_subscribed(); in is_subscribed()
|
| D | rx-observable.hpp | 437 if (!o->is_subscribed()) { in subscribe()
509 if (!o.is_subscribed()) { in detail_subscribe()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 63 if (!s.is_subscribed()) // Stop emitting if nobody is listening in __anon37f8ac850902()
79 if (!s.is_subscribed()) // Stop emitting if nobody is listening in __anon37f8ac850a02()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-range.hpp | 77 if (!dest.is_subscribed()) { in on_subscribe()
84 if (!dest.is_subscribed()) { in on_subscribe()
|
| D | rx-error.hpp | 74 if (!dest.is_subscribed()) { in on_subscribe()
|
| D | rx-iterate.hpp | 124 if (!state.out.is_subscribed()) { in on_subscribe()
|