Searched defs:serialize_observer (Results 1 – 1 of 1) sorted by relevance
209 struct serialize_observer struct in rxcpp::serialize_one_worker211 typedef serialize_observer<Observer> this_type;212 typedef rxu::decay_t<Observer> dest_type;213 typedef typename dest_type::value_type value_type;214 typedef observer<value_type, this_type> observer_type;215 dest_type dest;216 std::shared_ptr<std::mutex> lock;218 serialize_observer(dest_type d, std::shared_ptr<std::mutex> m) in serialize_observer() argument226 void on_next(value_type v) const { in on_next()230 void on_error(rxu::error_ptr e) const { in on_error()[all …]