Home
last modified time | relevance | path

Searched defs:flux (Results 1 – 7 of 7) sorted by relevance

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/
DFluxSingleTest.kt24 val flux = flux { in testSingleNoWait() constant
40 val flux = flux { in testSingleEmitAndAwait() constant
51 val flux = flux { in testSingleWithDelay() constant
62 val flux = flux { in testSingleException() constant
73 val flux = flux { in testAwaitSingleOrDefault() constant
84 val flux = flux { in testAwaitSingleOrDefaultException() constant
95 val flux = flux<String?> { in testAwaitSingleOrNull() constant
106 val flux = flux { in testAwaitSingleOrNullException() constant
117 val flux = flux { in testAwaitSingleOrElse() constant
128 val flux = flux { in testAwaitSingleOrElseException() constant
[all …]
DFluxMultiTest.kt19 val flux = flux { in <lambda>() constant
30 val flux = flux { in <lambda>() constant
49 val flux = flux(Dispatchers.Unconfined) { in <lambda>() constant
60 val flux = flux { in <lambda>() constant
70 val flux = flux { in <lambda>() constant
DFluxTest.kt18 val flux = flux(currentDispatcher()) { in <lambda>() constant
35 val flux = flux<String>(currentDispatcher()) { in <lambda>() constant
55 val flux = flux<String>(currentDispatcher()) { in <lambda>() constant
DConvertTest.kt99 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>() constant
113 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>() constant
DFlowAsFluxTest.kt17 val flux = flow<String> { in <lambda>() constant
DReactorContextTest.kt28 val flux = flux(Context.of(1, "1", 7, "7").asCoroutineContext()) { in <lambda>() constant
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DFlux.kt37 public fun <T> flux( in <lambda>() method
52 public fun <T> CoroutineScope.flux( in flux() method