arrow-effects-reactor-data / arrow.effects.reactor

Package arrow.effects.reactor

Types

CoroutineContextReactorScheduler object CoroutineContextReactorScheduler
FluxK data class FluxK<A> : FluxKOf<A>, FluxKKindedJ<A>
ForFluxK class ForFluxK
ForMonoK class ForMonoK
MonoK data class MonoK<A> : MonoKOf<A>, MonoKKindedJ<A>

Type Aliases

FluxKConnection typealias FluxKConnection = KindConnection<ForFluxK>
FluxKKindedJ typealias FluxKKindedJ<A> = Hk<ForFluxK, A>
FluxKOf typealias FluxKOf<A> = Kind<ForFluxK, A>
FluxKProc typealias FluxKProc<A> = (FluxKConnection, (Either<Throwable, A>) -> Unit) -> Unit
FluxKProcF typealias FluxKProcF<A> = (FluxKConnection, (Either<Throwable, A>) -> Unit) -> FluxKOf<Unit>
MonoKConnection typealias MonoKConnection = KindConnection<ForMonoK>
MonoKKindedJ typealias MonoKKindedJ<A> = Hk<ForMonoK, A>
MonoKOf typealias MonoKOf<A> = Kind<ForMonoK, A>
MonoKProc typealias MonoKProc<A> = (MonoKConnection, (Either<Throwable, A>) -> Unit) -> Unit
MonoKProcF typealias MonoKProcF<A> = (MonoKConnection, (Either<Throwable, A>) -> Unit) -> MonoKOf<Unit>

Extensions for External Classes

arrow.Kind  
reactor.core.publisher.Flux  
reactor.core.publisher.Mono  

Functions

FluxKConnection fun FluxKConnection(dummy: Unit = Unit): KindConnection<ForFluxK>
Connection for FluxK.
MonoKConnection fun MonoKConnection(dummy: Unit = Unit): KindConnection<ForMonoK>
Connection for MonoK.