Searched refs:produce_item (Results 1 – 1 of 1) sorted by relevance
124 …static std::function<void(const rxsc::schedulable&)> produce_item(std::size_t id, state_type state… in produce_item() function150 localState->worker.schedule(produce_time, produce_item(new_id, localState)); in on_next()