Searched refs:unsubscribed_time (Results 1 – 5 of 5) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | replay.cpp | 43 w.schedule_absolute(rxsc::test::unsubscribed_time,
156 w.schedule_absolute(rxsc::test::unsubscribed_time,
255 w.schedule_absolute(rxsc::test::unsubscribed_time,
385 w.schedule_absolute(rxsc::test::unsubscribed_time,
504 w.schedule_absolute(rxsc::test::unsubscribed_time,
623 w.schedule_absolute(rxsc::test::unsubscribed_time,
|
| D | publish.cpp | 181 w.schedule_absolute(rxsc::test::unsubscribed_time,
295 w.schedule_absolute(rxsc::test::unsubscribed_time,
394 w.schedule_absolute(rxsc::test::unsubscribed_time,
|
| D | filter.cpp | 334 w.schedule_absolute(rxsc::test::unsubscribed_time, [&res](const rxsc::schedulable&) { in __anond35f9fd90d02()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | coroutine.cpp | 37 w.advance_to(rxsc::test::unsubscribed_time);
98 w.advance_to(rxsc::test::unsubscribed_time);
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
| D | rx-test.hpp | 377 static const long unsubscribed_time = 1000; member in rxcpp::schedulers::test
511 … return start<T>(std::forward<F>(createSource), created_time, subscribed_time, unsubscribed_time); in start()
540 …ype_t<start_traits<F>>>(std::move(createSource), created_time, subscribed_time, unsubscribed_time); in start()
|