Package 

Class RxJava2AdapterExtKt

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description

    • Field Summary

      Fields 
      Modifier and Type Field Description

    • Constructor Summary

      Constructors 
      Constructor Description

    • Enum Constant Summary

      Enum Constants 
      Enum Constant Description

    • Method Summary

      Modifier and Type Method Description
      final static <T extends Any> Flux<T> toFlux(Flowable<T> $self) Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.
      final static <T extends Any> Flux<T> toFlux(Observable<T> $self, BackpressureStrategy strategy) Wraps an RxJava Observable and applies the given backpressure strategy.
      final static <T extends Any> Flowable<T> toFlowable(Flux<T> $self) Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through.
      final static <T extends Any> Flowable<T> toFlowable(Mono<T> $self) Wraps a Mono instance into a Flowable instance, composing the micro-fusion properties of the Flux through.
      final static Completable toCompletable(Mono<?> $self) Wraps a void-Mono instance into a RxJava Completable.
      final static Mono<Void> toMono(Completable $self) Wraps a RxJava Completable into a Mono instance.
      final static <T extends Any> Mono<T> toMono(Single<T> $self) Wraps a RxJava Single into a Mono instance.
      final static <T extends Any> Mono<T> toMono(Maybe<T> $self) Wraps an RxJava Maybe into a Mono instance.
      final static <T extends Any> Single<T> toSingle(Mono<T> $self) Wraps a Mono instance into a RxJava Single.
      final static <T extends Any> Observable<T> toObservable(Flux<T> $self) Wraps a Flux instance into a RxJava Observable.
      final static <T extends Any> Maybe<T> toMaybe(Mono<T> $self) WRaps Mono instance into an RxJava Maybe.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

    • Method Detail

      • toFlux

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Flux<T> toFlux(Flowable<T> $self)

        Wraps a Flowable instance into a Flux instance, composing the micro-fusion properties of the Flowable through.

      • toFlux

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Flux<T> toFlux(Observable<T> $self, BackpressureStrategy strategy)

        Wraps an RxJava Observable and applies the given backpressure strategy.

        Parameters:
        strategy - the back-pressure strategy, default is BUFFER

      • toFlowable

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Flowable<T> toFlowable(Flux<T> $self)

        Wraps a Flux instance into a Flowable instance, composing the micro-fusion properties of the Flux through.

      • toFlowable

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Flowable<T> toFlowable(Mono<T> $self)

        Wraps a Mono instance into a Flowable instance, composing the micro-fusion properties of the Flux through.

      • toCompletable

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static Completable toCompletable(Mono<?> $self)

        Wraps a void-Mono instance into a RxJava Completable.

      • toMono

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static Mono<Void> toMono(Completable $self)

        Wraps a RxJava Completable into a Mono instance.

      • toMono

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Mono<T> toMono(Single<T> $self)

        Wraps a RxJava Single into a Mono instance.

      • toMono

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Mono<T> toMono(Maybe<T> $self)

        Wraps an RxJava Maybe into a Mono instance.

      • toSingle

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Single<T> toSingle(Mono<T> $self)

        Wraps a Mono instance into a RxJava Single.

        If the Mono is empty, the single will signal a NoSuchElementException.

      • toObservable

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Observable<T> toObservable(Flux<T> $self)

        Wraps a Flux instance into a RxJava Observable.

      • toMaybe

        @Deprecated(message = "RxJava adapters are being removed from the scope of extensions.") final static <T extends Any> Maybe<T> toMaybe(Mono<T> $self)

        WRaps Mono instance into an RxJava Maybe.