Searched refs:produce_timeout (Results 1 – 1 of 1) sorted by relevance
134 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in timeout_observer()145 …static std::function<void(const rxsc::schedulable&)> produce_timeout(std::size_t id, state_type st… in produce_timeout() function170 localState->worker.schedule(produce_time, produce_timeout(new_id, localState)); in on_next()