public class Utils
Modifier and Type | Method and Description |
---|---|
static <SNAPSHOT,ELEMENT> |
doOnError(DataFeed<? extends SNAPSHOT,ELEMENT> $receiver,
Function1<? super java.lang.Throwable,Unit> action)
Returns a
class DataFeed that processes errors according to the provided action. |
static <SNAPSHOT,ELEMENT> |
mapErrors(DataFeed<? extends SNAPSHOT,ELEMENT> $receiver,
Function1<? super java.lang.Throwable,? extends java.lang.Throwable> transform)
Returns a
class DataFeed that transforms errors according to the provided transform function. |
static <ELEMENT> NonExistentClass |
mapErrors(NonExistentClass $receiver,
Function1<? super java.lang.Throwable,? extends java.lang.Throwable> transform)
Returns an Observable that transforms errors according to the provided transform function.
|
static <T> CordaFuture<T> |
toFuture(NonExistentClass $receiver)
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. |
static <A> NonExistentClass |
toObservable(CordaFuture<? extends A> $receiver) |
public static <A> NonExistentClass toObservable(CordaFuture<? extends A> $receiver)
public static <T> CordaFuture<T> toFuture(NonExistentClass $receiver)
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
public static <SNAPSHOT,ELEMENT> DataFeed<SNAPSHOT,ELEMENT> mapErrors(DataFeed<? extends SNAPSHOT,ELEMENT> $receiver, 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
public static <SNAPSHOT,ELEMENT> DataFeed<SNAPSHOT,ELEMENT> doOnError(DataFeed<? extends SNAPSHOT,ELEMENT> $receiver, Function1<? super java.lang.Throwable,Unit> action)
Returns a class DataFeed
that processes errors according to the provided action.
class DataFeed
public static <ELEMENT> NonExistentClass mapErrors(NonExistentClass $receiver, Function1<? super java.lang.Throwable,? extends java.lang.Throwable> transform)
Returns an Observable that transforms errors according to the provided transform function.