arrow-fx-reactor / arrow.fx.reactor / FluxK


data class FluxK<out A> : FluxKOf<A>


<init> FluxK(flux: Flux<out A>)


flux val flux: Flux<out A>


ap fun <B> ap(fa: FluxKOf<(A) -> B>): FluxK<B>
bracketCase A way to safely acquire a resource and release in the face of errors and cancellation. It uses ExitCase to distinguish between different exit cases when releasing the acquired <B> bracketCase(use: (A) -> FluxKOf<B>, release: (A, ExitCase<Throwable>) -> FluxKOf<Unit>): FluxK<B>
concatMap fun <B> concatMap(f: (A) -> FluxKOf<B>): FluxK<B>
continueOn fun continueOn(ctx: CoroutineContext): FluxK<A>
equals fun equals(other: Any?): Boolean
filterMap fun <B> filterMap(f: (A) -> Option<B>): FluxK<B>
flatMap fun <B> flatMap(f: (A) -> FluxKOf<B>): FluxK<B>
foldLeft fun <B> foldLeft(b: B, f: (B, A) -> B): B
foldRight fun <B> foldRight(lb: Eval<B>, f: (A, Eval<B>) -> Eval<B>): Eval<B>
hashCode fun hashCode(): Int
map fun <B> map(f: (A) -> B): FluxK<B>
runAsync fun runAsync(cb: (Either<Throwable, A>) -> FluxKOf<Unit>): FluxK<Unit>
runAsyncCancellable fun runAsyncCancellable(cb: (Either<Throwable, A>) -> FluxKOf<Unit>): FluxK<Disposable>
switchMap fun <B> switchMap(f: (A) -> FluxKOf<B>): FluxK<B>
traverse fun <G, B> traverse(GA: Applicative<G>, f: (A) -> Kind<G, B>): Kind<G, FluxK<B>>

Companion Object Functions

async Creates a FluxK that’ll run <A> ~~async~~(fa: FluxKProc<A>): FluxK<A>fun <A> async(fa: ((Either<Throwable, A>) -> Unit) -> Unit): FluxK<A>
asyncF fun <A> ~~asyncF~~(fa: FluxKProcF<A>): FluxK<A>
fun <A> asyncF(fa: ((Either<Throwable, A>) -> Unit) -> FluxKOf<Unit>): FluxK<A>
cancelable fun <A> ~~cancelable~~(fa: ((Either<Throwable, A>) -> Unit) -> CancelToken<ForFluxK>): FluxK<A>
cancelableF fun <A> ~~cancelableF~~(fa: ((Either<Throwable, A>) -> Unit) -> FluxKOf<CancelToken<ForFluxK>>): FluxK<A>
cancellable fun <A> cancellable(fa: ((Either<Throwable, A>) -> Unit) -> CancelToken<ForFluxK>): FluxK<A>
cancellableF fun <A> cancellableF(fa: ((Either<Throwable, A>) -> Unit) -> FluxKOf<CancelToken<ForFluxK>>): FluxK<A>
defer fun <A> defer(fa: () -> FluxKOf<A>): FluxK<A>
invoke operator fun <A> invoke(fa: () -> A): FluxK<A>
just fun <A> just(a: A): FluxK<A>
raiseError fun <A> raiseError(t: Throwable): FluxK<A>
tailRecM tailrec fun <A, B> tailRecM(a: A, f: (A) -> FluxKOf<Either<A, B>>): FluxK<B>

Companion Object Extension Functions

fx fun <A> FluxK.Companion.fx(c: suspend AsyncSyntax<ForFluxK>.() -> A): FluxK<A>
monadConcat fun FluxK.Companion.monadConcat(): FluxKMonad
monadErrorConcat fun FluxK.Companion.monadErrorConcat(): FluxKMonadError
monadErrorFlat fun FluxK.Companion.monadErrorFlat(): FluxKMonadError
monadErrorSwitch fun FluxK.Companion.monadErrorSwitch(): FluxKMonadError
monadFlat fun FluxK.Companion.monadFlat(): FluxKMonad
monadSwitch fun FluxK.Companion.monadSwitch(): FluxKMonad

Do you like Arrow?

Arrow Org