Searched refs:instant_event_it (Results 1 – 1 of 1) sorted by relevance
223 auto instant_event_it = async_instant_events_.begin(); in SortAndEmitAsyncEvents() local227 auto has_instant_event = instant_event_it != async_instant_events_.end(); in SortAndEmitAsyncEvents()231 auto emit_next_instant = [&instant_event_it, &has_instant_event, this]() { in SortAndEmitAsyncEvents()232 DoWriteEvent(*instant_event_it); in SortAndEmitAsyncEvents()233 instant_event_it++; in SortAndEmitAsyncEvents()234 has_instant_event = instant_event_it != async_instant_events_.end(); in SortAndEmitAsyncEvents()247 auto emit_next_instant_or_end = [&instant_event_it, &end_event_it, in SortAndEmitAsyncEvents()249 if ((*instant_event_it)["ts"].asInt64() <= in SortAndEmitAsyncEvents()256 auto emit_next_instant_or_begin = [&instant_event_it, &begin_event_it, in SortAndEmitAsyncEvents()259 if ((*instant_event_it)["ts"].asInt64() <= in SortAndEmitAsyncEvents()[all …]