Searched defs:flux (Results 1 – 7 of 7) sorted by relevance
24 val flux = flux { in testSingleNoWait() constant40 val flux = flux { in testSingleEmitAndAwait() constant51 val flux = flux { in testSingleWithDelay() constant62 val flux = flux { in testSingleException() constant73 val flux = flux { in testAwaitFirst() constant84 val flux = flux { in testAwaitFirstOrDefault() constant95 val flux = flux { in testAwaitFirstOrDefaultWithValues() constant106 val flux = flux<String?> { in testAwaitFirstOrNull() constant117 val flux = flux { in testAwaitFirstOrNullWithValues() constant128 val flux = flux { in testAwaitFirstOrElse() constant[all …]
19 val flux = flux { in <lambda>() constant30 val flux = flux { in <lambda>() constant49 val flux = flux(Dispatchers.Unconfined) { in <lambda>() constant60 val flux = flux { in <lambda>() constant70 val flux = flux { in <lambda>() constant
18 val flux = flux(currentDispatcher()) { in <lambda>() constant35 val flux = flux<String>(currentDispatcher()) { in <lambda>() constant55 val flux = flux<String>(currentDispatcher()) { in <lambda>() constant150 val flux = flux<Int>(Dispatchers.Unconfined) { in <lambda>() constant170 val flux = flux { in <lambda>() constant
100 val flux = c.consumeAsFlow().asFlux(Dispatchers.Unconfined) in <lambda>() constant114 val flux = c.consumeAsFlow().asFlux(Dispatchers.Unconfined) in <lambda>() constant
17 val flux = flow { in <lambda>() constant
28 val flux = flux(Context.of(1, "1", 7, "7").asCoroutineContext()) { in <lambda>() constant
32 public fun <T> flux( in <lambda>() method94 public fun <T> CoroutineScope.flux( method