Home
last modified time | relevance | path

Searched refs:identity_one_worker (Results 1 – 25 of 36) sorted by relevance

12

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
Drx-interval.hpp115 detail::defer_interval<Duration, identity_one_worker>::value, in interval()
116 typename detail::defer_interval<Duration, identity_one_worker>::observable_type>::type { in interval()
117 …return detail::defer_interval<Duration, identity_one_worker>::make(identity_current_threa… in interval()
135 detail::defer_interval<Duration, identity_one_worker>::value, in interval()
136 typename detail::defer_interval<Duration, identity_one_worker>::observable_type>::type { in interval()
137 …return detail::defer_interval<Duration, identity_one_worker>::make(when, period, identity… in interval()
Drx-timer.hpp116 detail::defer_timer<TimePointOrDuration, identity_one_worker>::value, in timer()
117 …typename detail::defer_timer<TimePointOrDuration, identity_one_worker>::observable_type>::type { in timer()
118 …return detail::defer_timer<TimePointOrDuration, identity_one_worker>::make(when, identity… in timer()
Drx-range.hpp120 -> observable<T, detail::range<T, identity_one_worker>> { in range()
121 return observable<T, detail::range<T, identity_one_worker>>( in range()
122 … detail::range<T, identity_one_worker>(first, last, step, identity_current_thread())); in range()
Drx-iterate.hpp161 …lue_type_t<detail::iterate_traits<Collection>>, detail::iterate<Collection, identity_one_worker>> { in iterate()
162 …alue_type_t<detail::iterate_traits<Collection>>, detail::iterate<Collection, identity_one_worker>>( in iterate()
163 … detail::iterate<Collection, identity_one_worker>(std::move(c), identity_immediate())); in iterate()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-coordination.hpp114 class identity_one_worker : public coordination_base class
156 explicit identity_one_worker(rxsc::scheduler sc) : factory(sc) {} in identity_one_worker() function in rxcpp::identity_one_worker
170 inline identity_one_worker identity_immediate() { in identity_immediate()
171 static identity_one_worker r(rxsc::make_immediate()); in identity_immediate()
175 inline identity_one_worker identity_current_thread() { in identity_current_thread()
176 static identity_one_worker r(rxsc::make_current_thread()); in identity_current_thread()
180 inline identity_one_worker identity_same_worker(rxsc::worker w) { in identity_same_worker()
181 return identity_one_worker(rxsc::make_same_worker(w)); in identity_same_worker()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-replay.hpp104 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
116 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
142 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
170 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
200 class Subject = rxsub::replay<SourceValue, identity_one_worker>,
Drx-skip_until.hpp216 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
219 …:detail::skip_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable, identity_one_worker>,
247 …until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<TriggerObservable>, identity_one_worker>,
Drx-take_until.hpp224 class Timer = typename rxu::defer_type<rxs::detail::timer, identity_one_worker>::type,
227 …:detail::take_until<SourceValue, rxu::decay_t<Observable>, TriggerObservable, identity_one_worker>,
255 …until<SourceValue, rxu::decay_t<Observable>, rxu::decay_t<TriggerObservable>, identity_one_worker>,
Drx-merge.hpp230 … class Merge = rxo::detail::merge<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
257 … rxu::defer_type<rxo::detail::merge, SourceValue, ObservableObservable, identity_one_worker>::type,
Drx-merge_delay_error.hpp244 …Merge = rxo::detail::merge_delay_error<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
271 …type<rxo::detail::merge_delay_error, SourceValue, ObservableObservable, identity_one_worker>::type,
Drx-amb.hpp238 class Amb = rxo::detail::amb<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
265 …me rxu::defer_type<rxo::detail::amb, SourceValue, ObservableObservable, identity_one_worker>::type,
Drx-concat.hpp249 … class Concat = rxo::detail::concat<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
276 …rxu::defer_type<rxo::detail::concat, SourceValue, ObservableObservable, identity_one_worker>::type,
Drx-sequence_equal.hpp225 …ue, rxu::decay_t<Observable>, rxu::decay_t<OtherObservable>, rxu::equal_to<>, identity_one_worker>,
239 …_t<Observable>, rxu::decay_t<OtherObservable>, rxu::decay_t<BinaryPredicate>, identity_one_worker>,
Drx-with_latest_from.hpp255 …class with_latest_from = rxo::detail::with_latest_from<identity_one_worker, rxu::detail::pack, rxu…
268 …class with_latest_from = rxo::detail::with_latest_from<identity_one_worker, ResolvedSelector, rxu:…
Drx-combine_latest.hpp255 …class combine_latest = rxo::detail::combine_latest<identity_one_worker, rxu::detail::pack, rxu::de…
268 …class combine_latest = rxo::detail::combine_latest<identity_one_worker, ResolvedSelector, rxu::dec…
Drx-zip.hpp287 …class Zip = rxo::detail::zip<identity_one_worker, rxu::detail::pack, rxu::decay_t<Observable>, rxu…
300 …class Zip = rxo::detail::zip<identity_one_worker, ResolvedSelector, rxu::decay_t<Observable>, rxu:…
Drx-window_time.hpp267 …WithTime = rxo::detail::window_with_time<SourceValue, rxu::decay_t<Duration>, identity_one_worker>,
292 …WithTime = rxo::detail::window_with_time<SourceValue, rxu::decay_t<Duration>, identity_one_worker>,
Drx-flat_map.hpp269 …u::decay_t<Observable>, rxu::decay_t<CollectionSelector>, ResultSelectorType, identity_one_worker>,
303 …<Observable>, rxu::decay_t<CollectionSelector>, rxu::decay_t<ResultSelector>, identity_one_worker>,
Drx-buffer_time.hpp271 …WithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, identity_one_worker>,
296 …WithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, identity_one_worker>,
Drx-time_interval.hpp125 class TimeInterval = rxo::detail::time_interval<SourceValue, identity_one_worker>,
Drx-timestamp.hpp119 class Timestamp = rxo::detail::timestamp<SourceValue, identity_one_worker>,
Drx-concat_map.hpp302 …u::decay_t<Observable>, rxu::decay_t<CollectionSelector>, ResultSelectorType, identity_one_worker>,
336 …<Observable>, rxu::decay_t<CollectionSelector>, rxu::decay_t<ResultSelector>, identity_one_worker>,
Drx-switch_on_next.hpp216 …chOnNext = rxo::detail::switch_on_next<SourceValue, rxu::decay_t<Observable>, identity_one_worker>,
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dreplay.cpp467 auto so = rx::identity_one_worker(sc);
586 auto so = rx::identity_one_worker(sc);
Dsequence_equal.cpp784 … .sequence_equal(ys, rxcpp::identity_one_worker(rxsc::make_current_thread())) in __anon811547631102()
839 ….sequence_equal(ys, [](int x, int y) { return x == y; }, rxcpp::identity_one_worker(rxsc::make_cur… in __anon811547631202()

12