Searched refs:notification_type (Results 1 – 3 of 3) sorted by relevance
163 typedef typename rxn::notification<T> notification_type; typedef in rxcpp::schedulers::detail::mock_observer164 typedef rxn::recorded<typename notification_type::type> recorded_type;190 typedef typename rxn::notification<T> notification_type; in make_subscriber() typedef191 typedef rxn::recorded<typename notification_type::type> recorded_type; in make_subscriber()200 recorded_type(ts->sc->clock(), notification_type::on_next(value))); in make_subscriber()206 recorded_type(ts->sc->clock(), notification_type::on_error(e))); in make_subscriber()212 recorded_type(ts->sc->clock(), notification_type::on_completed())); in make_subscriber()382 typedef typename rxn::notification<T> notification_type; typedef383 typedef rxn::recorded<typename notification_type::type> recorded_type;390 return recorded_type(ticks, notification_type::on_next(std::move(value))); in next()[all …]
28 typedef rxn::notification<T> notification_type; typedef29 typedef typename notification_type::type base_notification_type;108 fill_queue.push_back(notification_type::on_next(std::move(v))); in on_next()116 fill_queue.push_back(notification_type::on_error(e)); in on_error()124 fill_queue.push_back(notification_type::on_completed()); in on_completed()
67 typedef rxn::notification<T> notification_type; typedef68 typedef typename notification_type::type base_notification_type;189 state->fill_queue.push_back(notification_type::on_next(std::move(v))); in on_next()195 state->fill_queue.push_back(notification_type::on_error(e)); in on_error()201 state->fill_queue.push_back(notification_type::on_completed()); in on_completed()