Searched refs:rxFlowable (Results 1 – 14 of 14) sorted by relevance
29 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()42 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()55 rxFlowable<Int>(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()70 rxFlowable<Int>(Dispatchers.Unconfined) { in <lambda>()85 rxFlowable(Dispatchers.Unconfined) { in <lambda>()97 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()109 rxFlowable(Dispatchers.Unconfined + cehUnreached()) { in <lambda>()123 rxFlowable(Dispatchers.Unconfined) { in <lambda>()
16 val observable = rxFlowable(currentDispatcher()) { in <lambda>()33 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()53 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()76 rxFlowable(currentDispatcher()) { in <lambda>()112 val pub = rxFlowable(currentDispatcher()) { in <lambda>()
56 val flow = rxFlowable<Unit>(dispatcher) { throw TestException() }.asFlow() in <lambda>()81 val flow = rxFlowable<Unit>(dispatcher) { in <lambda>()
17 val observable = rxFlowable(currentDispatcher()) { in <lambda>()34 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()54 val observable = rxFlowable<String>(currentDispatcher()) { in <lambda>()77 rxFlowable(currentDispatcher()) { in <lambda>()113 val pub = rxFlowable(currentDispatcher()) { in <lambda>()
35 public fun <T: Any> rxFlowable( in rxFlowable() method50 public fun <T: Any> CoroutineScope.rxFlowable( method
32 public fun <T: Any> rxFlowable( in rxFlowable() method
49 …public static final fun rxFlowable (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Func…50 …public static final fun rxFlowable (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/Coroutin…51 …public static synthetic fun rxFlowable$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/fu…52 …public static synthetic fun rxFlowable$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/corouti…
44 …public static final fun rxFlowable (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Func…45 …public static synthetic fun rxFlowable$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/fu…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…64 [rxFlowable]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…68 [rxFlowable]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines…
51 * RxJava 2.x ([rxFlowable], [rxSingle], etc), and52 * RxJava 3.x ([rxFlowable], [rxSingle], etc), and282 [rxFlowable]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines…
441 * rxFlowable generic parameter is now restricted with Any.834 * Added a default value for `context` parameter to `rxFlowable` (see #146 by @PhilGlass).1054 * Introduced `rxFlowable` builder for Rx 2.x.1056 …* Fixed bug with sometimes missing `onComplete` in `publish`, `rxObservable`, and `rxFlowable` bui…