HomeSort by relevance Sort by last modified time
    Searched refs:is_subscribed (Results 1 - 25 of 25) sorted by null

  /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
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());
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/
rx-immediate.hpp 38 if (scbl.is_subscribed()) {
47 if (scbl.is_subscribed()) {
rx-newthread.hpp 101 return !keepAlive->lifetime.is_subscribed() || !keepAlive->q.empty();
104 if (!keepAlive->lifetime.is_subscribed()) {
108 if (!peek.what.is_subscribed()) {
134 if (scbl.is_subscribed()) {
rx-virtualtime.hpp 79 if (next.what.is_subscribed()) {
112 if (!next.what.is_subscribed()) {
215 if (scbl.is_subscribed()) {
rx-currentthread.hpp 85 if (!item.what.is_subscribed()) {
187 if (!scbl.is_subscribed()) {
209 if (scbl.is_subscribed()) {
226 if (what.is_subscribed()) {
rx-runloop.hpp 78 if (scbl.is_subscribed()) {
180 if (!peek.what.is_subscribed()) {
rx-test.hpp 253 if (o.is_subscribed()) {
308 if (o.is_subscribed()) {
  /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
create.cpp 63 if (!s.is_subscribed()) // Stop emitting if nobody is listening
79 if (!s.is_subscribed()) // Stop emitting if nobody is listening
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
rx-subject.hpp 71 return o.is_subscribed();
138 if (o.is_subscribed()) {
189 if (o.is_subscribed()) {
205 if (o.is_subscribed()) {
223 if (o.is_subscribed()) {
rx-synchronize.hpp 61 if (!destination.is_subscribed()) {
106 if (lifetime.is_subscribed()) {
114 if (lifetime.is_subscribed()) {
122 if (lifetime.is_subscribed()) {
rx-behavior.hpp 95 if (keepAlive.get_subscription().is_subscribed()) {
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-observe_on.hpp 122 if (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty()) {
132 if (drain_queue.empty() || !destination.is_subscribed()) {
134 if (!destination.is_subscribed() ||
135 (!lifetime.is_subscribed() && fill_queue.empty() && drain_queue.empty())) {
152 if (lifetime.is_subscribed()) break;
rx-concat.hpp 156 } else if (!state->sourceLifetime.is_subscribed()) {
203 if (state->collectionLifetime.is_subscribed()) {
215 if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) {
rx-concat_map.hpp 196 } else if (!state->sourceLifetime.is_subscribed()) {
242 if (state->collectionLifetime.is_subscribed()) {
254 if (!state->collectionLifetime.is_subscribed() && state->selectedCollections.empty()) {
rx-group_by.hpp 124 if (!state->source_lifetime.is_subscribed()) {
209 if (!dest.is_subscribed()) {
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-coroutine.hpp 61 if (!state->lifetime.is_subscribed()) {return false;}
94 return !!state && !rhs.state && !state->lifetime.is_subscribed();
rx-subscription.hpp 172 bool is_subscribed() const { function in class:rxcpp::subscription
287 } else if (s.is_subscribed()) {
370 // is_subscribed can only transition to 'false' once,
503 using subscription::is_subscribed;
585 bool is_subscribed() const { function in class:rxcpp::resource
586 return lifetime.is_subscribed();
rx-scheduler.hpp 234 inline bool is_subscribed() const { function in class:rxcpp::schedulers::worker
235 return lifetime.is_subscribed();
592 inline bool is_subscribed() const { function in class:rxcpp::schedulers::schedulable
593 return lifetime.is_subscribed();
620 if (is_subscribed()) {
626 if (is_subscribed()) {
632 if (is_subscribed()) {
641 if (!is_subscribed()) {
710 while (s.is_subscribed()) {
rx-subscriber.hpp 177 if (!is_subscribed()) {
184 if (!is_subscribed()) {
191 if (!is_subscribed()) {
200 bool is_subscribed() const { function in class:rxcpp::subscriber
201 return lifetime.is_subscribed();
    [all...]
rx-observable.hpp 437 if (!o->is_subscribed()) {
509 if (!o.is_subscribed()) {
    [all...]
  /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
rx-range.hpp 77 if (!dest.is_subscribed()) {
84 if (!dest.is_subscribed()) {
rx-error.hpp 74 if (!dest.is_subscribed()) {
rx-iterate.hpp 124 if (!state.out.is_subscribed()) {
  /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
subject.cpp 48 bool is_subscribed() {return issubscribed;} function in class:syncwithvoid::sync_subscriber
68 for (int i = 0; i < onnextcalls && scbr.is_subscribed(); i++) {
111 bool is_subscribed() {return issubscribed;} function in class:asyncwithready::async_subscriber
156 for (; i < onnextcalls && scbr.is_subscribed(); i++) {
186 bool is_subscribed() {return issubscribed;} function in class: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()) {
353 for (int i = 0; i < onnextcalls && o.is_subscribed(); i++) {
400 while(o.is_subscribed()) {
    [all...]

Completed in 3189 milliseconds