Lines Matching refs:OnNext
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()
280 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(trace_id::ma… in make_subscriber()
281 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
283 template<class T, class OnNext, class OnCompleted>
284 auto make_subscriber(const OnNext& on, const OnCompleted& oc) in make_subscriber()
286 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
288 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
289 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, … in make_subscriber()
290 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… 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()
295 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
298 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
299 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>… in make_subscriber()
300 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
343 template<class T, class OnNext>
344 auto make_subscriber(const composite_subscription& cs, const OnNext& on) in make_subscriber()
346 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
347 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
348 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(trace_id::make_next_i… in make_subscriber()
349 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
351 template<class T, class OnNext, class OnError>
352 auto make_subscriber(const composite_subscription& cs, const OnNext& on, const OnError& oe) in make_subscriber()
354 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
356 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
357 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(trace_id::ma… in make_subscriber()
358 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); 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()
363 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
365 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
366 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, … in make_subscriber()
367 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
369 template<class T, class OnNext, class OnError, class OnCompleted>
370 auto make_subscriber(const composite_subscription& cs, const OnNext& on, const OnError& oe, const O… in make_subscriber()
372 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
375 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
376 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>… in make_subscriber()
377 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
443 template<class T, class OnNext>
444 auto make_subscriber(trace_id id, const OnNext& on) in make_subscriber()
446 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
447 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
448 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(std::move(id), compos… in make_subscriber()
449 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
451 template<class T, class OnNext>
452 auto make_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on) in make_subscriber()
454 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
455 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
456 return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(std::move(id), cs, in make_subscriber()
457 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
459 template<class T, class OnNext, class OnError>
460 auto make_subscriber(trace_id id, const OnNext& on, const OnError& oe) in make_subscriber()
462 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
464 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
465 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(std::move(id… in make_subscriber()
466 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
468 template<class T, class OnNext, class OnError>
469 auto make_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
471 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
473 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
474 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(std::move(id… in make_subscriber()
475 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); 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()
480 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
482 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
483 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, … in make_subscriber()
484 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
486 template<class T, class OnNext, class OnCompleted>
487 auto make_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on, const OnCompl… in make_subscriber()
489 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
491 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
492 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, … in make_subscriber()
493 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… 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()
498 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
501 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
502 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>… 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 auto make_subscriber(trace_id id, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
508 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
511 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
512 …return subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>… in make_subscriber()
513 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
578 template<class T, class OtherT, class OtherObserver, class OnNext>
579 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on) in make_subscriber()
581 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
582 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
583 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(trace_id::make_next_… in make_subscriber()
584 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
588 template<class T, class OtherT, class OtherObserver, class OnNext>
589 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on) in make_subscriber()
591 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
592 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
593 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(std::move(id), scbr.… in make_subscriber()
594 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
598 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError>
599 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError… in make_subscriber()
601 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
603 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
604 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(trace_id::m… in make_subscriber()
605 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
609 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError>
610 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … in make_subscriber()
612 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
614 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
615 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(std::move(i… in make_subscriber()
616 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
620 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
621 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnCompl… in make_subscriber()
623 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
625 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
626 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty,… in make_subscriber()
627 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
631 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
632 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … in make_subscriber()
634 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
636 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
637 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty,… in make_subscriber()
638 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
642 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
643 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError… in make_subscriber()
645 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
648 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
649 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>… 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 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … in make_subscriber()
657 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
660 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
661 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>… in make_subscriber()
662 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()
721 template<class T, class OtherT, class OtherObserver, class OnNext>
722 …(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on) in make_subscriber()
724 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
725 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
726 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(trace_id::make_next_… in make_subscriber()
727 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
731 template<class T, class OtherT, class OtherObserver, class OnNext>
732 …iber<OtherT, OtherObserver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on) in make_subscriber()
734 detail::is_on_next_of<T, OnNext>::value, in make_subscriber()
735 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type { in make_subscriber()
736 auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>(std::move(id), cs, in make_subscriber()
737 observer<T, detail::stateless_observer_tag, OnNext>(on)); in make_subscriber()
741 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError>
742 …er<OtherT, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
744 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
746 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
747 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(trace_id::m… in make_subscriber()
748 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
752 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError>
753 …herObserver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
755 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
757 subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type { in make_subscriber()
758 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>(std::move(i… in make_subscriber()
759 observer<T, detail::stateless_observer_tag, OnNext, OnError>(on, oe)); in make_subscriber()
763 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
764 …er<OtherT, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on, const OnCompl… in make_subscriber()
766 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
768 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
769 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty,… in make_subscriber()
770 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
774 template<class T, class OtherT, class OtherObserver, class OnNext, class OnCompleted>
775 …herObserver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on, const OnCompl… in make_subscriber()
777 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
779 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnComple… in make_subscriber()
780 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty,… in make_subscriber()
781 …observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>(on, detail:… in make_subscriber()
785 template<class T, class OtherT, class OtherObserver, class OnNext, class OnError, class OnCompleted>
786 …er<OtherT, OtherObserver>& scbr, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
788 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
791 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
792 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>… 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 …herObserver>& scbr, trace_id id, const composite_subscription& cs, const OnNext& on, const OnError… in make_subscriber()
800 detail::is_on_next_of<T, OnNext>::value && in make_subscriber()
803 …subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type { in make_subscriber()
804 …auto r = subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>… in make_subscriber()
805 … observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>(on, oe, oc)); in make_subscriber()