arrow-fx-rx2 / arrow.fx.rx2.extensions

Package arrow.fx.rx2.extensions

Types

FlowableKApplicative interface FlowableKApplicative : Applicative<ForFlowableK>
FlowableKApplicativeError interface FlowableKApplicativeError : ApplicativeError<ForFlowableK, Throwable>, FlowableKApplicative
FlowableKAsync interface FlowableKAsync : Async<ForFlowableK>, FlowableKMonadDefer
FlowableKBracket interface FlowableKBracket : Bracket<ForFlowableK, Throwable>, FlowableKMonadThrow
FlowableKConcurrent interface FlowableKConcurrent : Concurrent<ForFlowableK>, FlowableKAsync
FlowableKConcurrentEffect interface FlowableKConcurrentEffect : ConcurrentEffect<ForFlowableK>, FlowableKEffect
FlowableKEffect interface FlowableKEffect : Effect<ForFlowableK>, FlowableKAsync
FlowableKFoldable interface FlowableKFoldable : Foldable<ForFlowableK>
FlowableKFunctor interface FlowableKFunctor : Functor<ForFlowableK>
FlowableKFunctorFilter interface FlowableKFunctorFilter : FunctorFilter<ForFlowableK>
FlowableKMonad interface FlowableKMonad : Monad<ForFlowableK>
FlowableKMonadDefer interface FlowableKMonadDefer : MonadDefer<ForFlowableK>, FlowableKBracket
FlowableKMonadError interface FlowableKMonadError : MonadError<ForFlowableK, Throwable>, FlowableKMonad
FlowableKMonadFilter interface FlowableKMonadFilter : MonadFilter<ForFlowableK>
FlowableKMonadThrow interface FlowableKMonadThrow : MonadThrow<ForFlowableK>, FlowableKMonadError
FlowableKTimer interface FlowableKTimer : Timer<ForFlowableK>
FlowableKTraverse interface FlowableKTraverse : Traverse<ForFlowableK>
MaybeKApplicative interface MaybeKApplicative : Applicative<ForMaybeK>
MaybeKApplicativeError interface MaybeKApplicativeError : ApplicativeError<ForMaybeK, Throwable>, MaybeKApplicative
MaybeKAsync interface MaybeKAsync : Async<ForMaybeK>, MaybeKMonadDefer
MaybeKBracket interface MaybeKBracket : Bracket<ForMaybeK, Throwable>, MaybeKMonadThrow
MaybeKConcurrent interface MaybeKConcurrent : Concurrent<ForMaybeK>, MaybeKAsync
MaybeKEffect interface MaybeKEffect : Effect<ForMaybeK>, MaybeKAsync
MaybeKFoldable interface MaybeKFoldable : Foldable<ForMaybeK>
MaybeKFunctor interface MaybeKFunctor : Functor<ForMaybeK>
MaybeKFunctorFilter interface MaybeKFunctorFilter : FunctorFilter<ForMaybeK>
MaybeKMonad interface MaybeKMonad : Monad<ForMaybeK>
MaybeKMonadDefer interface MaybeKMonadDefer : MonadDefer<ForMaybeK>, MaybeKBracket
MaybeKMonadError interface MaybeKMonadError : MonadError<ForMaybeK, Throwable>, MaybeKMonad
MaybeKMonadFilter interface MaybeKMonadFilter : MonadFilter<ForMaybeK>
MaybeKMonadThrow interface MaybeKMonadThrow : MonadThrow<ForMaybeK>, MaybeKMonadError
MaybeKTimer interface MaybeKTimer : Timer<ForMaybeK>
ObservableKApplicative interface ObservableKApplicative : Applicative<ForObservableK>
ObservableKApplicativeError interface ObservableKApplicativeError : ApplicativeError<ForObservableK, Throwable>, ObservableKApplicative
ObservableKAsync interface ObservableKAsync : Async<ForObservableK>, ObservableKMonadDefer
ObservableKBracket interface ObservableKBracket : Bracket<ForObservableK, Throwable>, ObservableKMonadThrow
ObservableKConcurrent interface ObservableKConcurrent : Concurrent<ForObservableK>, ObservableKAsync
ObservableKConcurrentEffect interface ObservableKConcurrentEffect : ConcurrentEffect<ForObservableK>, ObservableKEffect
ObservableKEffect interface ObservableKEffect : Effect<ForObservableK>, ObservableKAsync
ObservableKFoldable interface ObservableKFoldable : Foldable<ForObservableK>
ObservableKFunctor interface ObservableKFunctor : Functor<ForObservableK>
ObservableKFunctorFilter interface ObservableKFunctorFilter : FunctorFilter<ForObservableK>
ObservableKMonad interface ObservableKMonad : Monad<ForObservableK>
ObservableKMonadDefer interface ObservableKMonadDefer : MonadDefer<ForObservableK>, ObservableKBracket
ObservableKMonadError interface ObservableKMonadError : MonadError<ForObservableK, Throwable>, ObservableKMonad
ObservableKMonadFilter interface ObservableKMonadFilter : MonadFilter<ForObservableK>
ObservableKMonadThrow interface ObservableKMonadThrow : MonadThrow<ForObservableK>, ObservableKMonadError
ObservableKTimer interface ObservableKTimer : Timer<ForObservableK>
ObservableKTraverse interface ObservableKTraverse : Traverse<ForObservableK>
SingleKApplicative interface SingleKApplicative : Applicative<ForSingleK>
SingleKApplicativeError interface SingleKApplicativeError : ApplicativeError<ForSingleK, Throwable>, SingleKApplicative
SingleKAsync interface SingleKAsync : Async<ForSingleK>, SingleKMonadDefer
SingleKBracket interface SingleKBracket : Bracket<ForSingleK, Throwable>, SingleKMonadThrow
SingleKConcurrent interface SingleKConcurrent : Concurrent<ForSingleK>, SingleKAsync
SingleKConcurrentEffect interface SingleKConcurrentEffect : ConcurrentEffect<ForSingleK>, SingleKEffect
SingleKEffect interface SingleKEffect : Effect<ForSingleK>, SingleKAsync
SingleKFunctor interface SingleKFunctor : Functor<ForSingleK>
SingleKMonad interface SingleKMonad : Monad<ForSingleK>
SingleKMonadDefer interface SingleKMonadDefer : MonadDefer<ForSingleK>, SingleKBracket
SingleKMonadError interface SingleKMonadError : MonadError<ForSingleK, Throwable>, SingleKMonad
SingleKMonadThrow interface SingleKMonadThrow : MonadThrow<ForSingleK>, SingleKMonadError
SingleKTimer interface SingleKTimer : Timer<ForSingleK>

Companion Object Functions

asyncBuffer fun FlowableK.Companion.asyncBuffer(): FlowableKAsync
asyncDrop fun FlowableK.Companion.asyncDrop(): FlowableKAsync
asyncError fun FlowableK.Companion.asyncError(): FlowableKAsync
asyncLatest fun FlowableK.Companion.asyncLatest(): FlowableKAsync
asyncMissing fun FlowableK.Companion.asyncMissing(): FlowableKAsync
concurrent fun FlowableK.Companion.concurrent(dispatchers: Dispatchers<ForFlowableK>): Concurrent<ForFlowableK>
fun MaybeK.Companion.concurrent(dispatchers: Dispatchers<ForMaybeK>): Concurrent<ForMaybeK>
fun ObservableK.Companion.concurrent(dispatchers: Dispatchers<ForObservableK>): Concurrent<ForObservableK>
fun SingleK.Companion.concurrent(dispatchers: Dispatchers<ForSingleK>): Concurrent<ForSingleK>
effectBuffer fun FlowableK.Companion.effectBuffer(): FlowableKEffect
effectDrop fun FlowableK.Companion.effectDrop(): FlowableKEffect
effectError fun FlowableK.Companion.effectError(): FlowableKEffect
effectLatest fun FlowableK.Companion.effectLatest(): FlowableKEffect
effectMissing fun FlowableK.Companion.effectMissing(): FlowableKEffect
fx fun <A> FlowableK.Companion.fx(c: suspend AsyncSyntax<ForFlowableK>.() -> A): FlowableK<A>
fun <A> MaybeK.Companion.fx(c: suspend AsyncSyntax<ForMaybeK>.() -> A): MaybeK<A>
fun <A> ObservableK.Companion.fx(c: suspend AsyncSyntax<ForObservableK>.() -> A): ObservableK<A>
fun <A> SingleK.Companion.fx(c: suspend AsyncSyntax<ForSingleK>.() -> A): SingleK<A>
monadConcat fun FlowableK.Companion.monadConcat(): FlowableKMonad
fun ObservableK.Companion.monadConcat(): ObservableKMonad
monadErrorConcat fun FlowableK.Companion.monadErrorConcat(): FlowableKMonadError
fun ObservableK.Companion.monadErrorConcat(): ObservableKMonadError
monadErrorFlat fun FlowableK.Companion.monadErrorFlat(): FlowableKMonadError
fun ObservableK.Companion.monadErrorFlat(): ObservableKMonadError
monadErrorSwitch fun FlowableK.Companion.monadErrorSwitch(): FlowableKMonadError
fun ObservableK.Companion.monadErrorSwitch(): ObservableKMonadError
monadFlat fun FlowableK.Companion.monadFlat(): FlowableKMonad
fun ObservableK.Companion.monadFlat(): ObservableKMonad
monadSuspendBuffer fun FlowableK.Companion.monadSuspendBuffer(): FlowableKMonadDefer
monadSuspendDrop fun FlowableK.Companion.monadSuspendDrop(): FlowableKMonadDefer
monadSuspendError fun FlowableK.Companion.monadSuspendError(): FlowableKMonadDefer
monadSuspendLatest fun FlowableK.Companion.monadSuspendLatest(): FlowableKMonadDefer
monadSuspendMissing fun FlowableK.Companion.monadSuspendMissing(): FlowableKMonadDefer
monadSwitch fun FlowableK.Companion.monadSwitch(): FlowableKMonad
fun ObservableK.Companion.monadSwitch(): ObservableKMonad