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>;
275         !std::is_same<void, OnNext>::value,
276         rxu::decay_t<OnNext>,
464 template<class T, class DefaultOnError = detail::OnErrorEmpty, class U, class State, class OnNext, …
465 auto make_observer(observer<U, State, OnNext, OnError, OnCompleted> o)  in make_observer()  argument
466     ->      observer<T, State, OnNext, OnError, OnCompleted> {  in make_observer()
467     return  observer<T, State, OnNext, OnError, OnCompleted>(std::move(o));  in make_observer()
487 template<class T, class DefaultOnError = detail::OnErrorEmpty, class OnNext>
488 auto make_observer(OnNext on)  in make_observer()
490         detail::is_on_next_of<T, OnNext>::value,  in make_observer()
491             observer<T, detail::stateless_observer_tag, OnNext, DefaultOnError>>::type {  in make_observer()
492     return  observer<T, detail::stateless_observer_tag, OnNext, DefaultOnError>(  in make_observer()
504 template<class T, class DefaultOnError = detail::OnErrorEmpty, class OnNext, class OnError>
505 auto make_observer(OnNext on, OnError oe)  in make_observer()
507         detail::is_on_next_of<T, OnNext>::value &&  in make_observer()
509             observer<T, detail::stateless_observer_tag, OnNext, OnError>>::type {  in make_observer()
510     return  observer<T, detail::stateless_observer_tag, OnNext, OnError>(  in make_observer()
513 template<class T, class DefaultOnError = detail::OnErrorEmpty, class OnNext, class OnCompleted>
514 auto make_observer(OnNext on, OnCompleted oc)  in make_observer()
516         detail::is_on_next_of<T, OnNext>::value &&  in make_observer()
518 …          observer<T, detail::stateless_observer_tag, OnNext, DefaultOnError, OnCompleted>>::type {  in make_observer()
519     return  observer<T, detail::stateless_observer_tag, OnNext, DefaultOnError, OnCompleted>(  in make_observer()
522 template<class T, class DefaultOnError = detail::OnErrorEmpty, class OnNext, class OnError, class O…
523 auto make_observer(OnNext on, OnError oe, OnCompleted oc)  in make_observer()
525         detail::is_on_next_of<T, OnNext>::value &&  in make_observer()
528             observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>::type {  in make_observer()
529     return  observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(  in make_observer()
534 template<class T, class State, class OnNext>
535 auto make_observer(State os, OnNext on)  in make_observer()
539             observer<T, State, OnNext>>::type {  in make_observer()
540     return  observer<T, State, OnNext>(  in make_observer()
553 template<class T, class State, class OnNext, class OnError>
554 auto make_observer(State os, OnNext on, OnError oe)  in make_observer()
559             observer<T, State, OnNext, OnError>>::type {  in make_observer()
560     return  observer<T, State, OnNext, OnError>(  in make_observer()
563 template<class T, class State, class OnNext, class OnCompleted>
564 auto make_observer(State os, OnNext on, OnCompleted oc)  in make_observer()
568             observer<T, State, OnNext, void, OnCompleted>>::type {  in make_observer()
569     return  observer<T, State, OnNext, void, OnCompleted>(  in make_observer()
572 template<class T, class State, class OnNext, class OnError, class OnCompleted>
573 auto make_observer(State os, OnNext on, OnError oe, OnCompleted oc)  in make_observer()
578             observer<T, State, OnNext, OnError, OnCompleted>>::type {  in make_observer()
579     return  observer<T, State, OnNext, OnError, OnCompleted>(  in make_observer()
590 template<class T, class OnNext>
591 auto make_observer_dynamic(OnNext&& on)  in make_observer_dynamic()
593         detail::is_on_next_of<T, OnNext>::value,  in make_observer_dynamic()
596                 make_observer<T>(std::forward<OnNext>(on)));  in make_observer_dynamic()
598 template<class T, class OnNext, class OnError>
599 auto make_observer_dynamic(OnNext&& on, OnError&& oe)  in make_observer_dynamic()
601         detail::is_on_next_of<T, OnNext>::value &&  in make_observer_dynamic()
605                 make_observer<T>(std::forward<OnNext>(on), std::forward<OnError>(oe)));  in make_observer_dynamic()
607 template<class T, class OnNext, class OnCompleted>
608 auto make_observer_dynamic(OnNext&& on, OnCompleted&& oc)  in make_observer_dynamic()
610         detail::is_on_next_of<T, OnNext>::value &&  in make_observer_dynamic()
614                 make_observer<T>(std::forward<OnNext>(on), std::forward<OnCompleted>(oc)));  in make_observer_dynamic()
616 template<class T, class OnNext, class OnError, class OnCompleted>
617 auto make_observer_dynamic(OnNext&& on, OnError&& oe, OnCompleted&& oc)  in make_observer_dynamic()
619         detail::is_on_next_of<T, OnNext>::value &&  in make_observer_dynamic()
624 …make_observer<T>(std::forward<OnNext>(on), std::forward<OnError>(oe), std::forward<OnCompleted>(oc…  in make_observer_dynamic()