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

FlowableKMonad

@extension interface FlowableKMonad : Monad<ForFlowableK>

Functions

ap open fun <A, B> FlowableKOf<A>.ap(ff: FlowableKOf<(A) -> B>): FlowableK<B>
flatMap open fun <A, B> FlowableKOf<A>.flatMap(f: (A) -> FlowableKOf<B>): FlowableK<B>
just open fun <A> just(a: A): FlowableK<A>
map open fun <A, B> FlowableKOf<A>.map(f: (A) -> B): FlowableK<B>
tailRecM open fun <A, B> tailRecM(a: A, f: (A) -> FlowableKOf<Either<A, B>>): FlowableK<B>

Inheritors

FlowableKMonadError interface FlowableKMonadError : MonadError<ForFlowableK, Throwable>, FlowableKMonad