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

FluxKProc

typealias FluxKProc<A> = (FluxKConnection, (Either<Throwable, A>) -> Unit) -> Unit