Home
last modified time | relevance | path

Searched refs:inFlight (Results 1 – 2 of 2) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/
DFlatMapStressTest.kt48 val inFlight = inFlightElements.get() in <lambda>() constant
49 assertTrue(inFlight <= bufferSize + 1, in <lambda>()
50 "Expected less in flight elements than ${bufferSize + 1}, but had $inFlight") in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/scheduling/
DDispatcher.kt166 val inFlight = inFlightTasks.incrementAndGet() in execute() constant
169 if (inFlight <= parallelism) { in execute()