arrow-fx-rx2 / arrow.fx.rx2.extensions.flowablek.async / arrow.Kind

Extensions for arrow.Kind

continueOn fun <A> Kind<ForFlowableK, A>.continueOn(arg1: CoroutineContext): FlowableK<A>
Continue the evaluation on provided CoroutineContext
effectMap fun <A, B> Kind<ForFlowableK, A>.effectMap(arg1: suspend (A) -> B): FlowableK<B>
Helper function that provides an easy way to construct a suspend effect