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 -