Searched refs:asFlux (Results 1 – 8 of 8) sorted by relevance
2 …public static final fun asFlux (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/Cor…3 …public static synthetic fun asFlux$default (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/co…9 public static final fun asFlux (Lkotlinx/coroutines/flow/Flow;)Lreactor/core/publisher/Flux;40 public static final fun asFlux (Lkotlinx/coroutines/flow/Flow;)Lreactor/core/publisher/Flux;41 …public static final fun asFlux (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineContext;…42 …public static synthetic fun asFlux$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/Corou…
20 | [Flow.asFlux] | `Flux` | Converts the given flow to a TCK-compliant Flux.30 | [ReceiveChannel.asFlux][kotlinx.coroutines.channels.ReceiveChannel.asFlux] | Converts a streaming…44 [Flow.asFlux]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-reactor/kotlinx.corou…48 [kotlinx.coroutines.channels.ReceiveChannel.asFlux]: https://kotlin.github.io/kotlinx.coroutines/ko…
51 public fun <T> ReceiveChannel<T>.asFlux(context: CoroutineContext = EmptyCoroutineContext): Flux<T>… in <lambda>() method52 for (t in this@asFlux) in <lambda>()
17 public fun <T : Any> Flow<T>.asFluxDeprecated(): Flux<T> = asFlux()
28 public fun <T: Any> Flow<T>.asFlux(context: CoroutineContext = EmptyCoroutineContext): Flux<T> = in asFlux() method
20 .asFlux() in <lambda>()82 flowOf(42).asFlux().subscribe(object : Subscriber<Int> { in <lambda>()119 flowOf(42).asFlux(dispatcher).subscribe(object : Subscriber<Int> { in <lambda>()
99 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>()113 val flux = c.asFlux(Dispatchers.Unconfined) in <lambda>()
260 * New `Flow.asFlux ` builder.