| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| rx-buffer_time.hpp | 148 // on_next/on_error/oncompleted the timed schedule calls must be resheduled
149 // when they occur to ensure that production happens after on_next/on_error/oncompleted
153 localState->dest.on_next(std::move(localState->chunks.front()));
185 void on_next(T v) const { function in struct:rxcpp::operators::detail::buffer_with_time::buffer_with_time_observer
219 localState->dest.on_next(std::move(localState->chunks.front()));
|
| rx-buffer_time_count.hpp | 133 // on_next/on_error/oncompleted the timed schedule calls must be resheduled
134 // when they occur to ensure that production happens after on_next/on_error/oncompleted
147 state->dest.on_next(state->chunk);
166 void on_next(T v) const { function in struct:rxcpp::operators::detail::buffer_with_time_or_count::buffer_with_time_or_count_observer
198 localState->dest.on_next(localState->chunk);
|
| rx-debounce.hpp | 129 state->dest.on_next(*state->value);
143 void on_next(T v) const { function in struct:rxcpp::operators::detail::debounce::debounce_observer
180 localState->dest.on_next(*localState->value);
|
| rx-observe_on.hpp | 186 void on_next(source_value_type v) const { function in struct:rxcpp::operators::detail::observe_on::observe_on_observer
189 state->fill_queue.push_back(notification_type::on_next(std::move(v)));
|
| rx-sample_time.hpp | 120 localState->dest.on_next(*localState->value);
139 void on_next(T v) const { function in struct:rxcpp::operators::detail::sample_with_time::sample_with_time_observer
|
| rx-timeout.hpp | 163 void on_next(T v) const { function in struct:rxcpp::operators::detail::timeout::timeout_observer
169 localState->dest.on_next(v);
|
| rx-window_time.hpp | 140 // on_next/on_error/oncompleted the timed schedule calls must be resheduled
141 // when they occur to ensure that production happens after on_next/on_error/oncompleted
159 localState->dest.on_next(localState->subj[localState->subj.size() - 1].get_observable().as_dynamic());
182 void on_next(T v) const { function in struct:rxcpp::operators::detail::window_with_time::window_with_time_observer
186 s.get_subscriber().on_next(v);
|
| rx-window_time_count.hpp | 135 // on_next/on_error/oncompleted the timed schedule calls must be resheduled
136 // when they occur to ensure that production happens after on_next/on_error/oncompleted
151 state->dest.on_next(state->subj.get_observable().as_dynamic());
169 void on_next(T v) const { function in struct:rxcpp::operators::detail::window_with_time_or_count::window_with_time_or_count_observer
172 localState->subj.get_subscriber().on_next(v);
|
| rx-group_by.hpp | 199 void on_next(T v) const { function in struct:rxcpp::operators::detail::group_by::group_by_observer
223 dest.on_next(obs);
251 g->second.on_next(std::move(selectedMarble.get()));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| rx-coordination.hpp | 226 void on_next(value_type v) const { function in struct:rxcpp::serialize_one_worker::serialize_observer
228 dest.on_next(v);
|
| rx-notification.hpp | 131 os << "on_next( ";
143 o.on_next(value);
209 static type on_next(U value) { function in struct:rxcpp::notifications::notification
|
| rx-observer.hpp | 64 s.on_next(t);
67 s.on_next(t);
167 \brief consumes values from an observable using `State` that may implement on_next, on_error and on_completed with optional overrides of each function.
171 \tparam OnNext - the type of a function that matches `void(State&, T)`. Called 0 or more times. If `void` State::on_next will be called.
241 void on_next(T& t) const { function in class:rxcpp::observer
244 void on_next(T&& t) const { function in class:rxcpp::observer
293 static_assert(detail::is_on_next_of<T, on_next_t>::value, "Function supplied for on_next must be a function with the signature void(T);");
329 void on_next(T& t) const { function in class:rxcpp::observer
332 void on_next(T&& t) const { function in class:rxcpp::observer
353 virtual void on_next(T&) const {} function in struct:rxcpp::detail::virtual_observer
354 virtual void on_next(T&&) const {}; function in struct:rxcpp::detail::virtual_observer
368 virtual void on_next(T& t) const { function in struct:rxcpp::detail::specific_observer
371 virtual void on_next(T&& t) const { function in struct:rxcpp::detail::specific_observer
437 void on_next(V&& v) const { function in class:rxcpp::observer
[all...] |
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| rx-subject.hpp | 93 // used to avoid taking lock in on_next
178 void on_next(V v) const { function in class:rxcpp::subjects::detail::multicast_observer
190 o.on_next(v);
|
| rx-synchronize.hpp | 105 void on_next(V v) const { function in struct:rxcpp::subjects::detail::synchronize_observer::synchronize_observer_state
108 fill_queue.push_back(notification_type::on_next(std::move(v)));
150 void on_next(V v) const { function in class:rxcpp::subjects::detail::synchronize_observer
151 state->on_next(std::move(v));
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| subject.cpp | 30 std::cout << "loop mutex : " << n << " subscribed, " << c << " on_next calls, " << msElapsed.count() << "ms elapsed " << c / (msElapsed.count() / 1000.0) << " ops/sec" << std::endl;
50 void on_next(T v) { function in class:syncwithvoid::sync_subscriber
55 SCENARIO("for loop calls void on_next(int)", "[!hide][for][asyncobserver][baseline][perf]"){
58 WHEN("calling on_next 100 million times"){
69 scbr.on_next(i);
73 std::cout << "loop void : " << n << " subscribed, " << *c << " on_next calls, " << msElapsed.count() << "ms elapsed " << *c / (msElapsed.count() / 1000.0) << " ops/sec" << std::endl;
113 ready on_next(T v) { function in class:asyncwithready::async_subscriber
140 SCENARIO("for loop calls ready on_next(int)", "[!hide][for][asyncobserver][ready][perf]"){
143 WHEN("calling on_next 100 million times"){
157 auto controller = scbr.on_next(i)
188 std::future<unit> on_next(T v) { function in class:asyncwithfuture::async_subscriber
[all...] |
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| internal.h | 553 grpc_closure* on_next; /* protected by t combiner */ member in struct:grpc_chttp2_stream
|
