Home
last modified time | relevance | path

Searched refs:sinkTrigger (Results 1 – 2 of 2) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-take_until.hpp138 auto sinkTrigger = make_subscriber<typename trigger_source_type::value_type>( in on_subscribe() local
162 [&](){return state->coordinator.out(sinkTrigger);}, in on_subscribe()
Drx-skip_until.hpp128 auto sinkTrigger = make_subscriber<typename trigger_source_type::value_type>( in on_subscribe() local
159 [&](){return state->coordinator.out(sinkTrigger);}, in on_subscribe()