Home
last modified time | relevance | path

Searched refs:make_subscription (Results 1 – 13 of 13) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dsubscription.cpp329 auto es = rx::make_subscription();
370 auto s = rx::make_subscription([&i](){++i;}); in __anonfe564e912302()
404 auto s = rx::make_subscription();
428 s.add(rx::make_subscription());
429 s.add(rx::make_subscription([&i](){++i;})); in __anonfe564e912402()
Dobserver.cpp85 auto es = rx::make_subscription();
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscription.hpp219 inline auto make_subscription() in make_subscription() function
224 auto make_subscription(I&& i) in make_subscription() function
230 auto make_subscription(Unsubscribe&& u) in make_subscription() function
524 return add(make_subscription(std::move(f))); in add()
594 return lifetime.add(make_subscription(std::move(f))); in add()
Drx-scheduler.hpp601 return lifetime.add(make_subscription(std::move(f))); in add()
Drx-subscriber.hpp209 return lifetime.add(make_subscription(std::move(f))); in add()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-switch_on_next.hpp141 state->inner_lifetime.add(make_subscription([state, innerlifetimetoken](){ in on_subscribe()
Drx-merge.hpp159 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
Drx-merge_delay_error.hpp153 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
Drx-amb.hpp160 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
Drx-concat.hpp125 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()
Drx-flat_map.hpp182 innercs.add(make_subscription([state, innercstoken](){ in on_subscribe()
Drx-concat_map.hpp164 collectionLifetime.add(make_subscription([state, innercstoken](){ in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp319 o.add(rx::make_subscription([c, n](){ in __anon0164c1a70c02()
392 o.add(rx::make_subscription([c, n](){ in __anon0164c1a71302()