Searched refs:emitIndex (Results 1 – 2 of 2) sorted by relevance
68 val emitIndex = AtomicLong() in <lambda>() constant77 val value = emitIndex.getAndIncrement() in <lambda>()110 val fromEmitIndex = emitIndex.get() in <lambda>()115 … } while (emitIndex.get() < waitEmitIndex) // Ok, enough was emitted, wait more if not in <lambda>()
18 TEST(GeneratorTest, emitIndex) { in TEST() argument