public class Utils
@NotNull public static <A> rx.Observable<A> toObservable(@NotNull CordaFuture<? extends A> $this$toObservable)
@NotNull public static <T> CordaFuture<T> toFuture(@NotNull rx.Observable<T> $this$toFuture)
Returns a interface CordaFuture
bound to the first item emitted by this Observable. The future will complete with a
NoSuchElementException if no items are emitted or any other error thrown by the Observable. If it's cancelled then
it will unsubscribe from the observable.
interface CordaFuture
@NotNull public static <SNAPSHOT,ELEMENT> DataFeed<SNAPSHOT,ELEMENT> mapErrors(@NotNull DataFeed<? extends SNAPSHOT,ELEMENT> $this$mapErrors, @NotNull kotlin.jvm.functions.Function1<? super java.lang.Throwable,? extends java.lang.Throwable> transform)
Returns a class DataFeed
that transforms errors according to the provided transform
function.
class DataFeed
,
transform
@NotNull public static <SNAPSHOT,ELEMENT> DataFeed<SNAPSHOT,ELEMENT> doOnError(@NotNull DataFeed<? extends SNAPSHOT,ELEMENT> $this$doOnError, @NotNull kotlin.jvm.functions.Function1<? super java.lang.Throwable,kotlin.Unit> action)
Returns a class DataFeed
that processes errors according to the provided action
.
class DataFeed
,
action
@NotNull public static <ELEMENT> rx.Observable<ELEMENT> mapErrors(@NotNull rx.Observable<ELEMENT> $this$mapErrors, @NotNull kotlin.jvm.functions.Function1<? super java.lang.Throwable,? extends java.lang.Throwable> transform)
Returns an Observable that transforms errors according to the provided transform
function.
transform