arrow-fx-rx2 / arrow.fx.rx2

Package arrow.fx.rx2

Types

FlowableK data class FlowableK<out A> : FlowableKOf<A>
FlowableKOf typealias FlowableKOf<A> = Kind<ForFlowableK, A>
FlowableKProc typealias FlowableKProc<A> = ((Either<Throwable, A>) -> Unit) -> Unit
FlowableKProcF typealias FlowableKProcF<A> = ((Either<Throwable, A>) -> Unit) -> FlowableKOf<Unit>
ForFlowableK class ForFlowableK
ForMaybeK class ForMaybeK
ForObservableK class ForObservableK
ForSingleK class ForSingleK
MaybeK data class MaybeK<out A> : MaybeKOf<A>
MaybeKOf typealias MaybeKOf<A> = Kind<ForMaybeK, A>
MaybeKProc typealias MaybeKProc<A> = ((Either<Throwable, A>) -> Unit) -> Unit
MaybeKProcF typealias MaybeKProcF<A> = ((Either<Throwable, A>) -> Unit) -> Kind<ForMaybeK, Unit>
ObservableK data class ObservableK<out A> : ObservableKOf<A>
ObservableKOf typealias ObservableKOf<A> = Kind<ForObservableK, A>
ObservableKProc typealias ObservableKProc<A> = ((Either<Throwable, A>) -> Unit) -> Unit
ObservableKProcF typealias ObservableKProcF<A> = ((Either<Throwable, A>) -> Unit) -> ObservableKOf<Unit>
SingleK data class SingleK<out A> : SingleKOf<A>
SingleKOf typealias SingleKOf<A> = Kind<ForSingleK, A>
SingleKProc typealias SingleKProc<A> = ((Either<Throwable, A>) -> Unit) -> Unit
SingleKProcF typealias SingleKProcF<A> = ((Either<Throwable, A>) -> Unit) -> SingleKOf<Unit>

Extensions for External Classes

arrow.Kind  
io.reactivex.Flowable  
io.reactivex.Maybe  
io.reactivex.Observable  
io.reactivex.Single  
kotlin.coroutines.CoroutineContext  

Functions

FlowableKConnection Connection for FlowableK.fun FlowableKConnection(dummy: Unit = Unit): KindConnection<ForFlowableK>
handleErrorWith fun <A> FlowableK<A>.handleErrorWith(function: (Throwable) -> FlowableKOf<A>): FlowableK<A>
fun <A> MaybeK<A>.handleErrorWith(function: (Throwable) -> MaybeKOf<A>): MaybeK<A>
fun <A> SingleK<A>.handleErrorWith(function: (Throwable) -> SingleKOf<A>): SingleK<A>
MaybeKConnection Connection for MaybeK.fun MaybeKConnection(dummy: Unit = Unit): KindConnection<ForMaybeK>
ObservableKConnection Connection for ObservableK.fun ObservableKConnection(dummy: Unit = Unit): KindConnection<ForObservableK>
SingleKConnection Connection for SingleK.fun SingleKConnection(dummy: Unit = Unit): KindConnection<ForSingleK>
unsafeRunAsync fun <A> MaybeK<A>.unsafeRunAsync(cb: (Either<Throwable, A>) -> Unit): Unit
unsafeRunSync fun <A> MaybeK<A>.unsafeRunSync(): A

Do you like Arrow?

Arrow Org
<