Search

arrow-fx-rx2 / arrow.fx.rx2 / FlowableK

FlowableK

data class FlowableK<out A> : FlowableKOf<A>

Constructors

<init> FlowableK(flowable: Flowable<out A>)

Properties

flowable val flowable: Flowable<out A>

Functions

ap fun <B> ap(fa: FlowableKOf<(A) -> B>): FlowableK<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 resource.fun <B> bracketCase(use: (A) -> FlowableKOf<B>, release: (A, ExitCase<Throwable>) -> FlowableKOf<Unit>, mode: BackpressureStrategy = BackpressureStrategy.BUFFER): FlowableK<B>
concatMap fun <B> concatMap(f: (A) -> FlowableKOf<B>): FlowableK<B>
continueOn fun continueOn(ctx: CoroutineContext): FlowableK<A>
equals fun equals(other: Any?): Boolean
filterMap fun <B> filterMap(f: (A) -> Option<B>): FlowableK<B>
flatMap fun <B> flatMap(f: (A) -> FlowableKOf<B>): FlowableK<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): FlowableK<B>
runAsync fun runAsync(cb: (Either<Throwable, A>) -> FlowableKOf<Unit>): FlowableK<Unit>
runAsyncCancellable fun runAsyncCancellable(cb: (Either<Throwable, A>) -> FlowableKOf<Unit>): FlowableK<Disposable>
switchMap fun <B> switchMap(f: (A) -> FlowableKOf<B>): FlowableK<B>
traverse fun <G, B> traverse(GA: Applicative<G>, f: (A) -> Kind<G, B>): Kind<G, FlowableK<B>>

Companion Object Functions

async Creates a FlowableK that’ll run FlowableKProc.fun <A> async(fa: FlowableKProc<A>, mode: BackpressureStrategy = BackpressureStrategy.BUFFER): FlowableK<A>
asyncF fun <A> asyncF(fa: FlowableKProcF<A>, mode: BackpressureStrategy = BackpressureStrategy.BUFFER): FlowableK<A>
cancelable fun <A> cancelable(fa: ((Either<Throwable, A>) -> Unit) -> CancelToken<ForFlowableK>, mode: BackpressureStrategy = BackpressureStrategy.BUFFER): FlowableK<A>
cancelableF fun <A> cancelableF(fa: ((Either<Throwable, A>) -> Unit) -> FlowableKOf<CancelToken<ForFlowableK>>, mode: BackpressureStrategy = BackpressureStrategy.BUFFER): FlowableK<A>
defer fun <A> defer(fa: () -> FlowableKOf<A>): FlowableK<A>
invoke operator fun <A> invoke(fa: () -> A): FlowableK<A>
just fun <A> just(a: A): FlowableK<A>
raiseError fun <A> raiseError(t: Throwable): FlowableK<A>
tailRecM tailrec fun <A, B> tailRecM(a: A, f: (A) -> FlowableKOf<Either<A, B>>): FlowableK<B>

Extension Functions

handleErrorWith fun <A> FlowableK<A>.handleErrorWith(function: (Throwable) -> FlowableKOf<A>): FlowableK<A>

Companion Object Extension 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> = FlowableK.dispatchers()): Concurrent<ForFlowableK>
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 ConcurrentSyntax<ForFlowableK>.() -> A): FlowableK<A>
monadConcat fun FlowableK.Companion.monadConcat(): FlowableKMonad
monadErrorConcat fun FlowableK.Companion.monadErrorConcat(): FlowableKMonadError
monadErrorFlat fun FlowableK.Companion.monadErrorFlat(): FlowableKMonadError
monadErrorSwitch fun FlowableK.Companion.monadErrorSwitch(): FlowableKMonadError
monadFlat fun FlowableK.Companion.monadFlat(): FlowableKMonad
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