Lines Matching refs:OnCompleted
283 template<class T, class OnNext, class OnCompleted>
284 auto make_subscriber(const OnNext& on, const OnCompleted& oc) in make_subscriber()
287 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
288 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
289 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(trace_id::mak… in make_subscriber()
290 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
292 template<class T, class OnNext, class OnError, class OnCompleted>
293 auto make_subscriber(const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
297 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
298 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
299 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(trace_id::mak… in make_subscriber()
300 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
360 template<class T, class OnNext, class OnCompleted>
361 auto make_subscriber(const composite_subscription& cs, const OnNext& on, const OnCompleted& oc) in make_subscriber()
364 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
365 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
366 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(trace_id::mak… in make_subscriber()
367 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
369 template<class T, class OnNext, class OnError, class OnCompleted>
370 …riber(const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
374 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
375 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
376 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(trace_id::mak… in make_subscriber()
377 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
477 template<class T, class OnNext, class OnCompleted>
478 auto make_subscriber(trace_id id, const OnNext& on, const OnCompleted& oc) in make_subscriber()
481 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
482 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
483 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(std::move(id)… in make_subscriber()
484 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
486 template<class T, class OnNext, class OnCompleted>
487 …_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on, const OnCompleted& oc) in make_subscriber()
490 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
491 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
492 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(std::move(id)… in make_subscriber()
493 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
495 template<class T, class OnNext, class OnError, class OnCompleted>
496 auto make_subscriber(trace_id id, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
500 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
501 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
502 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(std::move(id)… in make_subscriber()
503 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
505 template<class T, class OnNext, class OnError, class OnCompleted>
506 …d id, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
510 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
511 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
512 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(std::move(id)… in make_subscriber()
513 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
620 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
621 …_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnCompleted& oc) in make_subscriber()
624 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
625 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
626 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(trace_id::mak… in make_subscriber()
627 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
631 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
632 …onst subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, const OnCompleted& oc) in make_subscriber()
635 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
636 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
637 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(std::move(id)… in make_subscriber()
638 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
642 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
643 …ubscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
647 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
648 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
649 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(trace_id::mak… in make_subscriber()
650 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
654 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
655 …erT, OtherObserver>& scbr, trace_id id, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
659 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
660 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
661 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(std::move(id)… in make_subscriber()
662 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
763 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
764 …T, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on, const OnCompleted& oc) in make_subscriber()
767 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
768 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
769 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(trace_id::mak… in make_subscriber()
770 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
774 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
775 …ver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on, const OnCompleted& oc) in make_subscriber()
778 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
779 … observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type { in make_subscriber()
780 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>(std::move(id)… in make_subscriber()
781 …erver<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail::On… in make_subscriber()
785 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
786 …scbr, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
790 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
791 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
792 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(trace_id::mak… in make_subscriber()
793 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
797 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
798 …d id, const composite_subscription& cs, const OnNext& on, const OnError& oe, const OnCompleted& oc) in make_subscriber()
802 detail::is_on_completed<OnCompleted>::value, in make_subscriber()
803 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
804 …iber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>(std::move(id)… in make_subscriber()
805 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()