arrow-fx-rx2 / arrow.fx.rx2.extensions / ObservableKMonadDefer

ObservableKMonadDefer

@extension interface ObservableKMonadDefer : MonadDefer<ForObservableK>, ObservableKBracket

Functions

defer open fun <A> defer(fa: () -> ObservableKOf<A>): ObservableK<A>

Extension Functions

catch fun <A> ApplicativeError<ForObservableK, Throwable>.catch(arg1: () -> A): ObservableK<A>

Inheritors

ObservableKAsync interface ObservableKAsync : Async<ForObservableK>, ObservableKMonadDefer