arrow-effects-rx2-data / arrow.effects.rx2 / ObservableKProcF

ObservableKProcF

typealias ObservableKProcF<A> = (ObservableKConnection, (Either<Throwable, A>) -> Unit) -> ObservableKOf<Unit>