Searched refs:asObservable (Results 1 – 12 of 12) sorted by relevance
22 }.asObservable() in <lambda>()39 }.asObservable() in <lambda>()58 }.asObservable() in <lambda>()75 }.asObservable() in <lambda>()108 }.asObservable() in <lambda>()125 }.asObservable() in <lambda>()141 }.asObservable() in <lambda>()153 flowOf(42).asObservable().subscribe(object : Observer<Int> { in <lambda>()186 flowOf(42).asObservable(dispatcher).subscribe(object : Observer<Int> { in <lambda>()
130 val observable = c.consumeAsFlow().asObservable() in <lambda>()144 val observable = c.consumeAsFlow().asObservable() in <lambda>()
97 checkNumbers(n, channel.consumeAsFlow().asObservable()) in <lambda>()
130 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>()144 val observable = c.consumeAsFlow().asObservable(Dispatchers.Unconfined) in <lambda>()
96 checkNumbers(n, channel.consumeAsFlow().asObservable(ctx(coroutineContext))) in <lambda>()
108 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obser… in asObservable() method149 public fun <T : Any> ReceiveChannel<T>.asObservable(context: CoroutineContext): Observable<T> = rxO… in asFlowable() method150 for (t in this@asObservable) in asFlowable()165 …servable(context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = asObservable(context)
108 public fun <T: Any> Flow<T>.asObservable(context: CoroutineContext = EmptyCoroutineContext) : Obser… in asObservable() method155 …servable(context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = asObservable(context)
20 | [Flow.asObservable] | `Observable` | Converts the given flow to a cold Observable.50 | [ReceiveChannel.asObservable][kotlinx.coroutines.channels.ReceiveChannel.asObservable] | Converts…70 [Flow.asObservable]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.cor…85 [kotlinx.coroutines.channels.ReceiveChannel.asObservable]: https://kotlin.github.io/kotlinx.corouti…
36 …public static final fun asObservable (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutin…37 …public static final fun asObservable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineCo…38 …public static synthetic fun asObservable$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines…
32 …public static final fun asObservable (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines/CoroutineCo…33 …public static synthetic fun asObservable$default (Lkotlinx/coroutines/flow/Flow;Lkotlin/coroutines…
20 | [Flow.asObservable] | `Observable` | Converts the given flow to a cold Observable.66 [Flow.asObservable]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.cor…