H R T

H

hu.akarnokd.rxjava3.interop - package hu.akarnokd.rxjava3.interop

R

RxJavaInterop - Class in hu.akarnokd.rxjava3.interop

Conversion methods for converting between 1.x and 3.x reactive types, composing backpressure and cancellation through.

T

toV1Completable(CompletableSource) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 3.x CompletableSource (the base type of 3.x Completable) into a 1.x Completable, composing cancellation (unsubscription) through.

toV1Completable(MaybeSource<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 3.x MaybeSource (the base type of 3.x Maybe) into a 1.x Completable, composing cancellation (unsubscription) through and ignoring the success value.

toV1Observable(Publisher<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts a Reactive-Streams Publisher of any kind (the base type of 3.x Flowable) into an 1.x Observable, composing the backpressure and cancellation (unsubscription) through.

toV1Observable(ObservableSource<T>, BackpressureStrategy) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts a 3.x ObservableSource (the base type of 3.x Observable) into an 1.x Observable instance, applying the specified backpressure strategy and composing the cancellation (unsubscription) through.

toV1Operator(FlowableOperator<R, T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x FlowableOperator into a 1.x Observable.Operator.

toV1Scheduler(Scheduler) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x Scheduler into a 1.x Scheduler.

toV1Single(SingleSource<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 3.x SingleSource (the base type of 3.x Single) into a 1.x Single, composing cancellation (unsubscription) through.

toV1Single(MaybeSource<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 3.x MaybeSource (the base type of 3.x Maybe) into a 1.x Single, composing cancellation (unsubscription) through and signalling NoSuchElementException if the MaybeSource is empty.

toV1Subject(Subject<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Wraps a 3.x Subject into a 1.x Subject.

toV1Subject(FlowableProcessor<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Wraps a 3.x FlowableProcessor into a 1.x Subject.

toV1Subscription(Disposable) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x Disposable into a 1.x Subscription.

toV1Transformer(FlowableTransformer<T, R>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x FlowableTransformer into a 1.x Observable.Transformer.

toV1Transformer(ObservableTransformer<T, R>, BackpressureStrategy) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x ObservableTransformer into a 1.x Observable.Transformer.

toV1Transformer(SingleTransformer<T, R>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x SingleTransformer into a 1.x Single.Transformer.

toV1Transformer(CompletableTransformer) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x CompletableTransformer into a 1.x Completable.Transformer.

toV3Completable(Completable) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Completable into a 3.x Completable, composing cancellation (unsubscription) through.

toV3Disposable(Subscription) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Subscription into a 3.x Disposable.

toV3Flowable(Observable<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Observable into a 3.x Flowable, composing the backpressure and cancellation (unsubscription) through.

toV3Maybe(Completable) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Completable into a 3.x Maybe, composing cancellation (unsubscription) through.

toV3Maybe(Single<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Single into a 3.x Maybe, composing cancellation (unsubscription) through.

toV3Observable(Observable<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Observable into a 3.x Observable, cancellation (unsubscription) through.

toV3Operator(Observable.Operator<R, T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Observable.Operator into a 3.x FlowableOperator.

toV3Processor(Subject<T, T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Wraps a 1.x Subject into a 3.x FlowableProcessor.

toV3Scheduler(Scheduler) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 3.x Scheduler into a 1.x Scheduler.

toV3Single(Single<T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Converts an 1.x Single into a 3.x Single, composing cancellation (unsubscription) through.

toV3Subject(Subject<T, T>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Wraps a 1.x Subject into a 3.x Subject.

toV3Transformer(Observable.Transformer<T, R>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Observable.Transformer into a 3.x FlowableTransformer.

toV3Transformer(Observable.Transformer<T, R>, BackpressureStrategy) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Observable.Transformer into a 3.x ObservableTransformer.

toV3Transformer(Single.Transformer<T, R>) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Single.Transformer into a 3.x SingleTransformer.

toV3Transformer(Completable.Transformer) - Static method in class hu.akarnokd.rxjava3.interop.RxJavaInterop

Convert the 1.x Completable.Transformer into a 3.x CompletableTransformer.

H R T