Searched refs:OnNext (Results 1 – 4 of 4) sorted by relevance
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscriber.hpp | 266 template<class T, class OnNext>
267 auto make_subscriber(const OnNext& on) in make_subscriber()
269 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
270 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
271 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(trace_id::make_next_i… in make_subscriber()
272 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
274 template<class T, class OnNext, class OnError>
275 auto make_subscriber(const OnNext& on, const OnError& oe) in make_subscriber()
277 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
279 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
[all …]
|
| D | rx-observer.hpp | 43 template<class T, class State, class OnNext>
47 using onnext_t = rxu::decay_t<OnNext>;
178 template<class T, class State, class OnNext, class OnError, class OnCompleted>
182 using this_type = observer<T, State, OnNext, OnError, OnCompleted>;
185 !std::is_same<void, OnNext>::value,
186 rxu::decay_t<OnNext>,
187 detail::OnNextForward<T, State, OnNext>>::type;
269 template<class T, class OnNext, class OnError, class OnCompleted>
270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_b…
273 using this_type = observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
[all …]
|
| D | rx-predef.hpp | 77 template<class T, class State = void, class OnNext = void, class OnError = void, class OnCompleted …
81 template<class T, class OnNext, class OnError, class OnCompleted>
82 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/ |
| D | subject.cpp | 37 template<class T, class OnNext>
41 OnNext onnext;
43 explicit sync_subscriber(OnNext on) in sync_subscriber()
98 template<class T, class OnNext>
102 OnNext onnext;
105 explicit async_subscriber(OnNext on) in async_subscriber()
175 template<class T, class OnNext>
179 OnNext onnext;
181 explicit async_subscriber(OnNext on) in async_subscriber()
|