Searched refs:on_produced_and_committed (Results 1 – 2 of 2) sorted by relevance
60 std::function<void()> on_produced_and_committed) in FakeProducer() argument64 on_produced_and_committed_(on_produced_and_committed) {} in FakeProducer()116 std::function<void()> on_produced_and_committed) in FakeProducerDelegate() argument119 on_produced_and_committed_(on_produced_and_committed) {} in FakeProducerDelegate()
79 auto on_produced_and_committed = task_runner.CreateCheckpoint(cname); in BenchmarkProducer() local80 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed)); in BenchmarkProducer()161 auto on_produced_and_committed = task_runner.CreateCheckpoint(cname); in BenchmarkConsumer() local162 producer->ProduceEventBatch(helper.WrapTask(on_produced_and_committed)); in BenchmarkConsumer()