Lines Matching refs:oe
77 explicit OnErrorForward(onerror_t oe) : onerror(std::move(oe)) {} in OnErrorForward()
496 auto make_observer(OnError oe) in make_observer() argument
502 detail::OnNextEmpty<T>(), std::move(oe)); in make_observer()
505 auto make_observer(OnNext on, OnError oe) in make_observer() argument
511 std::move(on), std::move(oe)); in make_observer()
523 auto make_observer(OnNext on, OnError oe, OnCompleted oc) in make_observer() argument
530 std::move(on), std::move(oe), std::move(oc)); in make_observer()
544 auto make_observer(State os, OnError oe) in make_observer() argument
551 std::move(os), detail::OnNextEmpty<T>(), std::move(oe)); in make_observer()
554 auto make_observer(State os, OnNext on, OnError oe) in make_observer() argument
561 std::move(os), std::move(on), std::move(oe)); in make_observer()
573 auto make_observer(State os, OnNext on, OnError oe, OnCompleted oc) in make_observer() argument
580 std::move(os), std::move(on), std::move(oe), std::move(oc)); in make_observer()
599 auto make_observer_dynamic(OnNext&& on, OnError&& oe) in make_observer_dynamic() argument
605 make_observer<T>(std::forward<OnNext>(on), std::forward<OnError>(oe))); in make_observer_dynamic()
617 auto make_observer_dynamic(OnNext&& on, OnError&& oe, OnCompleted&& oc) in make_observer_dynamic() argument
624 …make_observer<T>(std::forward<OnNext>(on), std::forward<OnError>(oe), std::forward<OnCompleted>(oc… in make_observer_dynamic()