public abstract class RxJava1Adapter
extends java.lang.Object
Observable
. Single
and Completable
to/from a Reactive Streams Publisher
.Modifier and Type | Method and Description |
---|---|
static Mono<java.lang.Void> |
completableToMono(rx.Completable completable) |
static <T> Flux<T> |
observableToFlux(rx.Observable<T> obs) |
static rx.Completable |
publisherToCompletable(org.reactivestreams.Publisher<?> source) |
static <T> rx.Observable<T> |
publisherToObservable(org.reactivestreams.Publisher<T> publisher) |
static <T> rx.Single<T> |
publisherToSingle(org.reactivestreams.Publisher<T> publisher) |
static <T> Mono<T> |
singleToMono(rx.Single<T> single) |
public static Mono<java.lang.Void> completableToMono(rx.Completable completable)
completable
- public static <T> Flux<T> observableToFlux(rx.Observable<T> obs)
T
- obs
- public static <T> rx.Observable<T> publisherToObservable(org.reactivestreams.Publisher<T> publisher)
T
- publisher
- public static <T> rx.Single<T> publisherToSingle(org.reactivestreams.Publisher<T> publisher)
T
- publisher
- public static rx.Completable publisherToCompletable(org.reactivestreams.Publisher<?> source)
source
- public static <T> Mono<T> singleToMono(rx.Single<T> single)
T
- single
-