Searched refs:on_next (Results 1 – 7 of 7) sorted by relevance
56 U&& on_next, in SubscribeAsync() argument62 on_next=std::forward<U>(on_next), in SubscribeAsync()67 std::forward<decltype(on_next)>(on_next), in SubscribeAsync()
150 dest.on_next(InodeResult::makeSuccess(inode, value_filename)); in EmitInodes()
345 dest.on_next(*res); in EmitFromCommandWithArgv()
623 dest.on_next(std::move(copy)); in TreeTraversalPreOrderObservableImpl()
628 history_id_subscriber_->on_next(history->id); in RecordDbLaunchHistory()830 subscriber_->on_next(std::cref(e)); in OnNext()886 …subscriber_->on_next(std::pair<RequestId, JobScheduledEvent>{std::move(request_id), std::move(e)}); in OnNext()
457 dest.on_next(std::move(state_change)); in EmitNext()
332 sub.on_next(std::move(out)); in SelectPageCacheFtraceEvents()