Searched refs:buffer_with_time (Results 1 – 4 of 4) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | buffer.cpp | 51 buffer_with_time(period, skip, rxcpp::observe_on_new_thread());
73 buffer_with_time(period, skip);
93 buffer_with_time(period, skip);
112 buffer_with_time(period, skip);
130 buffer_with_time(std::chrono::milliseconds(4), rxcpp::observe_on_new_thread());
149 buffer_with_time(std::chrono::milliseconds(4));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-buffer_time.hpp | 67 struct buffer_with_time struct
89 buffer_with_time(duration_type period, duration_type skip, coordination_type coordination) in buffer_with_time() function
256 auto buffer_with_time(AN&&... an) in buffer_with_time() function
271 …class BufferWithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, identity…
284 …class BufferWithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, rxu::dec…
296 …class BufferWithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, identity…
309 …class BufferWithTime = rxo::detail::buffer_with_time<SourceValue, rxu::decay_t<Duration>, rxu::dec…
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | buffer.cpp | 481 | rxo::buffer_with_time(TIME(3 UNIT), so);
526 .buffer_with_time(TIME(3 UNIT))
570 .buffer_with_time(TIME(4 UNIT), TIME(2 UNIT), so)
614 .buffer_with_time(TIME(4 UNIT), TIME(2 UNIT))
661 .buffer_with_time(TIME(4 UNIT), TIME(2 UNIT), so)
707 .buffer_with_time(milliseconds(100), milliseconds(70), so) in __anon79d0578d1e02()
764 .buffer_with_time(milliseconds(70), milliseconds(100), so) in __anon79d0578d1f02()
821 .buffer_with_time(milliseconds(100), milliseconds(70), so) in __anon79d0578d2002()
877 .buffer_with_time(milliseconds(100), milliseconds(70), so) in __anon79d0578d2102()
929 .buffer_with_time(milliseconds(100), so) in __anon79d0578d2202()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-observable.hpp | 964 auto buffer_with_time(AN&&... an) const in buffer_with_time() function in rxcpp::observable
|