arrow-effects-rx2-data / arrow.effects.rx2

Package arrow.effects.rx2

Types

CoroutineContextRx2Scheduler object CoroutineContextRx2Scheduler
FlowableK data class FlowableK<A> : FlowableKOf<A>, FlowableKKindedJ<A>
ForFlowableK class ForFlowableK
ForMaybeK class ForMaybeK
ForObservableK class ForObservableK
ForSingleK class ForSingleK
MaybeK data class MaybeK<A> : MaybeKOf<A>, MaybeKKindedJ<A>
ObservableK data class ObservableK<A> : ObservableKOf<A>, ObservableKKindedJ<A>
SingleK data class SingleK<A> : SingleKOf<A>, SingleKKindedJ<A>

Type Aliases

FlowableKConnection typealias FlowableKConnection = KindConnection<ForFlowableK>
FlowableKKindedJ typealias FlowableKKindedJ<A> = Hk<ForFlowableK, A>
FlowableKOf typealias FlowableKOf<A> = Kind<ForFlowableK, A>
FlowableKProc typealias FlowableKProc<A> = (FlowableKConnection, (Either<Throwable, A>) -> Unit) -> Unit
FlowableKProcF typealias FlowableKProcF<A> = (FlowableKConnection, (Either<Throwable, A>) -> Unit) -> FlowableKOf<Unit>
MaybeKConnection typealias MaybeKConnection = KindConnection<ForMaybeK>
MaybeKKindedJ typealias MaybeKKindedJ<A> = Hk<ForMaybeK, A>
MaybeKOf typealias MaybeKOf<A> = Kind<ForMaybeK, A>
MaybeKProc typealias MaybeKProc<A> = (MaybeKConnection, (Either<Throwable, A>) -> Unit) -> Unit
MaybeKProcF typealias MaybeKProcF<A> = (MaybeKConnection, (Either<Throwable, A>) -> Unit) -> Kind<ForMaybeK, Unit>
ObservableKConnection typealias ObservableKConnection = KindConnection<ForObservableK>
ObservableKKindedJ typealias ObservableKKindedJ<A> = Hk<ForObservableK, A>
ObservableKOf typealias ObservableKOf<A> = Kind<ForObservableK, A>
ObservableKProc typealias ObservableKProc<A> = (ObservableKConnection, (Either<Throwable, A>) -> Unit) -> Unit
ObservableKProcF typealias ObservableKProcF<A> = (ObservableKConnection, (Either<Throwable, A>) -> Unit) -> ObservableKOf<Unit>
SingleKConnection typealias SingleKConnection = KindConnection<ForSingleK>
SingleKKindedJ typealias SingleKKindedJ<A> = Hk<ForSingleK, A>
SingleKOf typealias SingleKOf<A> = Kind<ForSingleK, A>
SingleKProc typealias SingleKProc<A> = (SingleKConnection, (Either<Throwable, A>) -> Unit) -> Unit
SingleKProcF typealias SingleKProcF<A> = (SingleKConnection, (Either<Throwable, A>) -> Unit) -> SingleKOf<Unit>

Extensions for External Classes

arrow.Kind  
io.reactivex.Flowable  
io.reactivex.Maybe  
io.reactivex.Observable  
io.reactivex.Single  

Functions

FlowableKConnection fun FlowableKConnection(dummy: Unit = Unit): KindConnection<ForFlowableK>
Connection for FlowableK.
MaybeKConnection fun MaybeKConnection(dummy: Unit = Unit): KindConnection<ForMaybeK>
Connection for MaybeK.
ObservableKConnection fun ObservableKConnection(dummy: Unit = Unit): KindConnection<ForObservableK>
Connection for ObservableK.
SingleKConnection fun SingleKConnection(dummy: Unit = Unit): KindConnection<ForSingleK>
Connection for SingleK.