Lines Matching refs:subscriber
25 class subscriber : public subscriber_base<T> class
29 typedef subscriber<T, Observer> this_type;
103 subscriber();
107 subscriber(const this_type& o) in subscriber() function in rxcpp::subscriber
113 subscriber(this_type&& o) in subscriber() function in rxcpp::subscriber
121 friend class subscriber;
124 subscriber( in subscriber() function in rxcpp::subscriber
125 const subscriber<T, O>& o, in subscriber()
136 subscriber(trace_id id, composite_subscription cs, U&& o) in subscriber() function in rxcpp::subscriber
169 subscriber<T> as_dynamic() const { in as_dynamic()
170 return subscriber<T>(id, lifetime, destination.as_dynamic()); in as_dynamic()
225 subscriber<T, Observer> o) in make_subscriber()
226 -> subscriber<T, Observer> { in make_subscriber()
227 return subscriber<T, Observer>(std::move(o)); in make_subscriber()
237 … subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>>::type { in make_subscriber()
238 …return subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>(trace… in make_subscriber()
245 -> subscriber<T, observer<T, I>> { in make_subscriber()
246 …return subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), composite_subscriptio… in make_subscriber()
253 subscriber<T, Observer>>::type { in make_subscriber()
254 …return subscriber<T, Observer>(trace_id::make_next_id_subscriber(), composite_subscription(), o… in make_subscriber()
263 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
264 …return subscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), composite_subs… 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()
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()
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()
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()
308 -> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>> { in make_subscriber()
309 …return subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>(trace… in make_subscriber()
316 -> subscriber<T, observer<T, I>> { in make_subscriber()
317 return subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), cs, o); in make_subscriber()
321 const subscriber<T, I>& s) in make_subscriber()
322 -> subscriber<T, I> { in make_subscriber()
323 return subscriber<T, I>(trace_id::make_next_id_subscriber(), cs, s.get_observer()); in make_subscriber()
330 subscriber<T, Observer>>::type { in make_subscriber()
331 return subscriber<T, Observer>(trace_id::make_next_id_subscriber(), cs, o); in make_subscriber()
340 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
341 …return subscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), cs, make_obser… 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()
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()
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()
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()
385 -> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>> { in make_subscriber()
386 …return subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>(std::… in make_subscriber()
392 -> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>> { in make_subscriber()
393 …return subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>(std::… in make_subscriber()
400 -> subscriber<T, observer<T, I>> { in make_subscriber()
401 return subscriber<T, observer<T, I>>(std::move(id), composite_subscription(), o); in make_subscriber()
406 -> subscriber<T, observer<T, I>> { in make_subscriber()
407 return subscriber<T, observer<T, I>>(std::move(id), cs, o); in make_subscriber()
413 subscriber<T, Observer>>::type { in make_subscriber()
414 return subscriber<T, Observer>(std::move(id), composite_subscription(), o); in make_subscriber()
420 subscriber<T, Observer>>::type { in make_subscriber()
421 return subscriber<T, Observer>(std::move(id), cs, o); in make_subscriber()
430 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
431 return subscriber<T, observer<T, Observer>>(std::move(id), composite_subscription(), o); in make_subscriber()
440 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
441 return subscriber<T, observer<T, Observer>>(std::move(id), cs, o); 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()
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()
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()
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()
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()
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()
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()
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()
520 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, in make_subscriber()
522 -> subscriber<T, observer<T, I>> { in make_subscriber()
523 …auto r = subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), scbr.get_subscriptio… in make_subscriber()
528 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, in make_subscriber()
530 -> subscriber<T, observer<T, I>> { in make_subscriber()
531 auto r = subscriber<T, observer<T, I>>(std::move(id), scbr.get_subscription(), o); in make_subscriber()
536 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const Observer& o) in make_subscriber()
539 subscriber<T, Observer>>::type { in make_subscriber()
540 auto r = subscriber<T, Observer>(std::move(id), scbr.get_subscription(), o); in make_subscriber()
545 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const Observer& o) in make_subscriber()
549 subscriber<T, Observer>>::type { in make_subscriber()
550 …auto r = subscriber<T, Observer>(trace_id::make_next_id_subscriber(), scbr.get_subscription(), o… in make_subscriber()
555 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const Observer& o) in make_subscriber()
561 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
562 …auto r = subscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), scbr.get_subs… in make_subscriber()
567 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const Observer& o) in make_subscriber()
573 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
574 auto r = subscriber<T, observer<T, Observer>>(std::move(id), scbr.get_subscription(), o); in make_subscriber()
579 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on) 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()
589 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on) 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()
599 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError… 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()
610 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … 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()
621 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnCompl… 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()
632 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … 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()
643 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const OnNext& on, const OnError… 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()
655 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const OnNext& on, … 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()
668 auto make_subscriber(const subscriber<OtherT, OtherObserver>& , const composite_subscription& cs, in make_subscriber()
670 -> subscriber<T, observer<T, I>> { in make_subscriber()
671 return subscriber<T, observer<T, I>>(trace_id::make_next_id_subscriber(), cs, o); in make_subscriber()
674 auto make_subscriber(const subscriber<OtherT, OtherObserver>&, trace_id id, const composite_subscri… in make_subscriber()
676 -> subscriber<T, observer<T, I>> { in make_subscriber()
677 return subscriber<T, observer<T, I>>(std::move(id), cs, o); in make_subscriber()
680 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… in make_subscriber()
683 subscriber<T, Observer>>::type { in make_subscriber()
684 auto r = subscriber<T, Observer>(trace_id::make_next_id_subscriber(), cs, o); in make_subscriber()
689 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… in make_subscriber()
692 subscriber<T, Observer>>::type { in make_subscriber()
693 auto r = subscriber<T, Observer>(std::move(id), cs, o); in make_subscriber()
698 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… in make_subscriber()
704 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
705 auto r = subscriber<T, observer<T, Observer>>(trace_id::make_next_id_subscriber(), cs, o); in make_subscriber()
710 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… in make_subscriber()
716 subscriber<T, observer<T, Observer>>>::type { in make_subscriber()
717 auto r = subscriber<T, observer<T, Observer>>(std::move(id), cs, o); in make_subscriber()
722 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… 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()
732 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… 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()
742 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… 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()
753 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… 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()
764 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… 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()
775 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… 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()
786 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, const composite_subscription& c… 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()
798 auto make_subscriber(const subscriber<OtherT, OtherObserver>& scbr, trace_id id, const composite_su… 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()
811 auto make_subscriber(const subscriber<T, Observer>& scbr, const composite_subscription& cs) in make_subscriber()
812 -> subscriber<T, Observer> { in make_subscriber()
813 auto r = subscriber<T, Observer>(scbr.get_id(), cs, scbr.get_observer()); in make_subscriber()
818 auto make_subscriber(const subscriber<T, Observer>& scbr, trace_id id, const composite_subscription… in make_subscriber()
819 -> subscriber<T, Observer> { in make_subscriber()
820 auto r = subscriber<T, Observer>(std::move(id), cs, scbr.get_observer()); in make_subscriber()
826 auto make_subscriber(const subscriber<T, Observer>& scbr, trace_id id) in make_subscriber()
827 -> subscriber<T, Observer> { in make_subscriber()
828 auto r = subscriber<T, Observer>(std::move(id), scbr.get_subscription(), scbr.get_observer()); in make_subscriber()