| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-replay.hpp | 109 …return Result(Multicast(std::forward<Observable>(o), Subject(identity_current_thread(), composite_… in member()
121 … return Result(Multicast(std::forward<Observable>(o), Subject(identity_current_thread(), cs))); in member()
147 …return Result(Multicast(std::forward<Observable>(o), Subject(count, identity_current_thread(), cs)… in member()
175 …t(std::forward<Observable>(o), Subject(std::forward<Duration>(d), identity_current_thread(), cs))); in member()
205 …forward<Observable>(o), Subject(count, std::forward<Duration>(d), identity_current_thread(), cs))); in member()
|
| D | rx-time_interval.hpp | 128 -> decltype(o.template lift<Value>(TimeInterval(identity_current_thread()))) { in member()
129 return o.template lift<Value>(TimeInterval(identity_current_thread())); in member()
|
| D | rx-timestamp.hpp | 123 -> decltype(o.template lift<Value>(Timestamp(identity_current_thread()))) { in member()
124 return o.template lift<Value>(Timestamp(identity_current_thread())); in member()
|
| D | rx-buffer_time.hpp | 274 … -> decltype(o.template lift<Value>(BufferWithTime(period, period, identity_current_thread()))) { in member()
275 … return o.template lift<Value>(BufferWithTime(period, period, identity_current_thread())); in member()
299 …thTime(std::forward<Duration>(period), std::forward<Duration>(skip), identity_current_thread()))) { in member()
300 …WithTime(std::forward<Duration>(period), std::forward<Duration>(skip), identity_current_thread())); in member()
|
| D | rx-window_time.hpp | 270 … -> decltype(o.template lift<Value>(WindowWithTime(period, period, identity_current_thread()))) { in member()
271 … return o.template lift<Value>(WindowWithTime(period, period, identity_current_thread())); in member()
295 …thTime(std::forward<Duration>(period), std::forward<Duration>(skip), identity_current_thread()))) { in member()
296 …WithTime(std::forward<Duration>(period), std::forward<Duration>(skip), identity_current_thread())); in member()
|
| D | rx-merge.hpp | 235 return Result(Merge(std::forward<Observable>(o), identity_current_thread())); in member()
262 …(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_current_thread())); in member()
|
| D | rx-take_until.hpp | 231 auto cn = identity_current_thread(); in member()
259 …Until(std::forward<Observable>(o), std::forward<TriggerObservable>(t), identity_current_thread())); in member()
|
| D | rx-sample_time.hpp | 218 …template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), identity_current_thread()))) { in member()
219 …o.template lift<SourceValue>(SampleWithTime(std::forward<Duration>(d), identity_current_thread())); in member()
|
| D | rx-merge_delay_error.hpp | 249 return Result(Merge(std::forward<Observable>(o), identity_current_thread())); in member()
276 …(Merge(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_current_thread())); in member()
|
| D | rx-skip_until.hpp | 223 auto cn = identity_current_thread(); in member()
251 …Until(std::forward<Observable>(o), std::forward<TriggerObservable>(t), identity_current_thread())); in member()
|
| D | rx-amb.hpp | 243 return Result(Amb(std::forward<Observable>(o), identity_current_thread())); in member()
270 …lt(Amb(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_current_thread())); in member()
|
| D | rx-delay.hpp | 199 …cltype(o.template lift<SourceValue>(delay(std::forward<Duration>(d), identity_current_thread()))) { in member()
200 …urn o.template lift<SourceValue>(delay(std::forward<Duration>(d), identity_current_thread())); in member()
|
| D | rx-concat.hpp | 254 return Result(Concat(std::forward<Observable>(o), identity_current_thread())); in member()
281 …Concat(rxs::from(o.as_dynamic(), v0.as_dynamic(), vn.as_dynamic()...), identity_current_thread())); in member()
|
| D | rx-buffer_time_count.hpp | 248 …e lift<Value>(BufferTimeCount(std::forward<Duration>(period), count, identity_current_thread()))) { in member()
249 …ate lift<Value>(BufferTimeCount(std::forward<Duration>(period), count, identity_current_thread())); in member()
|
| D | rx-combine_latest.hpp | 260 …return Result(combine_latest(identity_current_thread(), rxu::pack(), std::make_tuple(std::forward<… in member()
273 …return Result(combine_latest(identity_current_thread(), std::forward<Selector>(s), std::make_tuple… in member()
|
| D | rx-with_latest_from.hpp | 260 …return Result(with_latest_from(identity_current_thread(), rxu::pack(), std::make_tuple(std::forwar… in member()
273 …return Result(with_latest_from(identity_current_thread(), std::forward<Selector>(s), std::make_tup… in member()
|
| D | rx-sequence_equal.hpp | 229 …d<Observable>(o), std::forward<OtherObservable>(t), rxu::equal_to<>(), identity_current_thread())); in member()
243 …std::forward<OtherObservable>(t), std::forward<BinaryPredicate>(pred), identity_current_thread())); in member()
|
| D | rx-timeout.hpp | 246 …type(o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), identity_current_thread()))) { in member()
247 …n o.template lift<SourceValue>(Timeout(std::forward<Duration>(d), identity_current_thread())); in member()
|
| D | rx-window_time_count.hpp | 254 …e lift<Value>(WindowTimeCount(std::forward<Duration>(period), count, identity_current_thread()))) { in member()
255 …ate lift<Value>(WindowTimeCount(std::forward<Duration>(period), count, identity_current_thread())); in member()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | delay.cpp | 9 auto scheduler = rxcpp::identity_current_thread();
34 auto scheduler = rxcpp::identity_current_thread();
|
| D | interval.cpp | 20 auto scheduler = rxcpp::identity_current_thread();
46 auto scheduler = rxcpp::identity_current_thread();
|
| D | timestamp.cpp | 15 time_point start = rxcpp::identity_current_thread().now();
45 time_point start = rxcpp::identity_current_thread().now();
|
| D | debounce.cpp | 9 auto scheduler = rxcpp::identity_current_thread();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/ |
| D | rx-interval.hpp | 117 …terval<Duration, identity_one_worker>::make(identity_current_thread().now(), period, identity_curr… in interval()
137 …tail::defer_interval<Duration, identity_one_worker>::make(when, period, identity_current_thread()); in interval()
|
| D | rx-timer.hpp | 118 …tail::defer_timer<TimePointOrDuration, identity_one_worker>::make(when, identity_current_thread()); in timer()
|