Lines Matching refs:oe
275 auto make_subscriber(const OnNext& on, const OnError& oe) in make_subscriber() argument
281 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
293 auto make_subscriber(const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber() argument
300 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
352 auto make_subscriber(const composite_subscription& cs, const OnNext& on, const OnError& oe) in make_subscriber() argument
358 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
370 auto make_subscriber(const composite_subscription& cs, const OnNext& on, const OnError& oe, const O… in make_subscriber() argument
377 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
460 auto make_subscriber(trace_id id, const OnNext& on, const OnError& oe) in make_subscriber() argument
466 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
469 …make_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on, const OnError& oe) in make_subscriber() argument
475 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
496 auto make_subscriber(trace_id id, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber() argument
503 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
506 …_id id, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& … in make_subscriber() argument
513 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
599 …make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError& oe) in make_subscriber() argument
605 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
610 …er(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, const OnError& oe) in make_subscriber() argument
616 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
643 … subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError& oe, const OnCompleted& … in make_subscriber() argument
650 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
655 …therT, OtherObserver>& scbr, trace_id id, const OnNext& on, const OnError& oe, const OnCompleted& … in make_subscriber() argument
662 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
742 …therT, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on, const OnError& oe) in make_subscriber() argument
748 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
753 …bserver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on, const OnError& oe) in make_subscriber() argument
759 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
786 …& scbr, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& … in make_subscriber() argument
793 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
798 …_id id, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& … in make_subscriber() argument
805 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()