public class Utils
Modifier and Type | Method and Description |
---|---|
static <T> CordaFuture<T> |
toFuture(rx.Observable<T> $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> rx.Observable<A> |
toObservable(CordaFuture<? extends A> $receiver) |
public static <A> rx.Observable<A> toObservable(CordaFuture<? extends A> $receiver)
public static <T> CordaFuture<T> toFuture(rx.Observable<T> $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