Searched refs:produce_buffer (Results 1 – 2 of 2) sorted by relevance
138 localState->worker.schedule(produce_buffer(new_id, produce_time, localState)); in buffer_with_time_or_count_observer()142 …static std::function<void(const rxsc::schedulable&)> produce_buffer(int id, rxsc::scheduler::clock… in produce_buffer() function152 state->worker.schedule(produce_buffer(new_id, produce_time, state)); in produce_buffer()171 … produce_buffer(localState->chunk_id, localState->worker.now(), localState)(self); in on_next()
152 auto produce_buffer = [localState](const rxsc::schedulable&) { in buffer_with_time_observer() local157 [&](){return localState->coordinator.act(produce_buffer);}, in buffer_with_time_observer()