arrow-effects-rx2-extensions / arrow.effects.rx2.extensions / FlowableKAsync

FlowableKAsync

@extension interface FlowableKAsync : Async<ForFlowableK>, FlowableKMonadDefer

Functions

async open fun <A> async(fa: Proc<A>): FlowableK<A>
asyncF open fun <A> asyncF(k: ProcF<ForFlowableK, A>): FlowableKOf<A>
continueOn open fun <A> FlowableKOf<A>.continueOn(ctx: CoroutineContext): FlowableK<A>

Inherited Functions

BS open fun BS(): BackpressureStrategy

Extension Functions

catch fun <A> ApplicativeError<ForFlowableK, Throwable>.catch(arg1: () -> A): FlowableK<A>

Inheritors

FlowableKEffect interface FlowableKEffect : Effect<ForFlowableK>, FlowableKAsync