arrow-effects-reactor-data / arrow.effects.reactor / FluxKProcF

FluxKProcF

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