179 class observer : public observer_base<T>  class
182     using this_type = observer<T, State, OnNext, OnError, OnCompleted>;
205 …explicit observer(state_t s, on_next_t n = on_next_t(), on_error_t e = on_error_t(), on_completed_…  in observer()  function in rxcpp::observer
212     explicit observer(state_t s, on_next_t n, on_completed_t c)  in observer()  function in rxcpp::observer
219     observer(const this_type& o)  in observer()  function in rxcpp::observer
226     observer(this_type&& o)  in observer()  function in rxcpp::observer
253     observer<T> as_dynamic() const {  in as_dynamic()
254         return observer<T>(*this);  in as_dynamic()
270 class observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted> : public observer_b…  class
273     using this_type = observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>;
297     observer()  in observer()  function in rxcpp::observer
304     explicit observer(on_next_t n, on_error_t e = on_error_t(), on_completed_t c = on_completed_t())  in observer()  function in rxcpp::observer
310     observer(const this_type& o)  in observer()  function in rxcpp::observer
316     observer(this_type&& o)  in observer()  function in rxcpp::observer
341     observer<T> as_dynamic() const {  in as_dynamic()
342         return observer<T>(*this);  in as_dynamic()
393 class observer<T, void, void, void, void> : public observer_base<T>  class
399     using this_type = observer<T, void, void, void, void>;
412     observer()  in observer()  function in rxcpp::observer
415     observer(const this_type& o)  in observer()  function in rxcpp::observer
419     observer(this_type&& o)  in observer()  function in rxcpp::observer
425     explicit observer(Observer o)  in observer()  function in rxcpp::observer
453     observer<T> as_dynamic() const {  in as_dynamic()
460     ->      observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>, DefaultOnError> {  in make_observer()
461     return  observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>, DefaultOnError>();  in make_observer()
465 auto make_observer(observer<U, State, OnNext, OnError, OnCompleted> o)  in make_observer()
466     ->      observer<T, State, OnNext, OnError, OnCompleted> {  in make_observer()
467     return  observer<T, State, OnNext, OnError, OnCompleted>(std::move(o));  in make_observer()
484             observer<T, Observer>>::type {  in make_observer()
485     return  observer<T, Observer>(std::move(ob));  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()
500             observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>, OnError>>::type {  in make_observer()
501     return  observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>, OnError>(  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()
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()
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()
539             observer<T, State, OnNext>>::type {  in make_observer()
540     return  observer<T, State, OnNext>(  in make_observer()
549             observer<T, State, detail::OnNextEmpty<T>, OnError>>::type {  in make_observer()
550     return  observer<T, State, detail::OnNextEmpty<T>, OnError>(  in make_observer()
559             observer<T, State, OnNext, OnError>>::type {  in make_observer()
560     return  observer<T, State, OnNext, OnError>(  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()
578             observer<T, State, OnNext, OnError, OnCompleted>>::type {  in make_observer()
579     return  observer<T, State, OnNext, OnError, OnCompleted>(  in make_observer()
587             observer<T>>::type {  in make_observer_dynamic()
588     return  observer<T>(std::move(o));  in make_observer_dynamic()
594             observer<T>>::type {  in make_observer_dynamic()
595     return  observer<T>(  in make_observer_dynamic()
603             observer<T>>::type {  in make_observer_dynamic()
604     return  observer<T>(  in make_observer_dynamic()
612             observer<T>>::type {  in make_observer_dynamic()
613     return  observer<T>(  in make_observer_dynamic()
622             observer<T>>::type {  in make_observer_dynamic()
623     return  observer<T>(  in make_observer_dynamic()