arrow-effects-reactor-extensions / arrow.effects.reactor.extensions.fluxk.concurrentEffect / arrow.Kind

Extensions for arrow.Kind

runAsyncCancellable fun <A> Kind<ForFluxK, A>.runAsyncCancellable(arg1: (Either<Throwable, A>) -> Kind<ForFluxK, Unit>): FluxK<() -> Unit>