Searched refs:RX_HANDLER (Results 1 – 2 of 2) sorted by relevance
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxFlowable.kt | 41 return Flowable.fromPublisher(publishInternal(GlobalScope, context, RX_HANDLER, block)) in rxFlowable()
53 ): Flowable<T> = Flowable.fromPublisher(publishInternal(this, context, RX_HANDLER, block))
55 private val RX_HANDLER: (Throwable, CoroutineContext) -> Unit = ::handleUndeliverableException constant
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxFlowable.kt | 38 return Flowable.fromPublisher(publishInternal(GlobalScope, context, RX_HANDLER, block)) in rxFlowable()
41 private val RX_HANDLER: (Throwable, CoroutineContext) -> Unit = ::handleUndeliverableException constant
|