blockingAwait |
Subscribes to and awaits the termination of this Completable instance in a blocking manner and rethrows any exception emitted. fun Publisher<*>.blockingAwait(): Unit |
blockingGet |
Waits in a blocking fashion until the current Single signals a success value (which is returned) or an exception (which is propagated). fun <T> Publisher<T>.blockingGet(): T |
completable |
Provides a Completable from this Publisher. fun Publisher<*>.completable(): Completable |
maybe |
Provides a Maybe from this Publisher. fun <T> Publisher<T>.maybe(): Maybe<T> |
single |
Provides a SingleResult from this Publisher. fun <T> Publisher<T>.single(): Single<T> |
toObservable |
Provides an Observable from a Publisher. fun <T> Publisher<T>.toObservable(): Observable<T> |