Package io.reactivex.rxjava3.internal.operators.single
package io.reactivex.rxjava3.internal.operators.single
-
ClassDescriptionSingleAmb<T>SingleCache<T>SingleCreate<T>SingleDefer<T>SingleDelay<T>SingleDematerialize<T,
R> Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.SingleDetach<T>Breaks the references between the upstream and downstream when the Maybe terminates.Calls a consumer after pushing the current item to the downstream.Calls an action after pushing the current item or an error to the downstream.Execute an action after an onSuccess, onError or a dispose event.Invokes callbacks upononSubscribefrom upstream anddisposefrom downstream.Calls a callback when the upstream calls onSubscribe with a disposable.SingleEquals<T>SingleError<T>SingleFlatMap<T,R> SingleFlatMapBiSelector<T,U, R> Maps a source item to another SingleSource then calls a BiFunction with the original item and the secondary item to generate the final result.Maps the success value of the source SingleSource into a Completable.Maps a success value into an Iterable and streams it back as a Flowable.Maps a success value into an Iterable and streams it back as an Observable.SingleFlatMapMaybe<T,R> Maps a value into a SingleSource and relays its signal.A Flowable that emits items based on applying a specified function to the item emitted by the source Single, where that function returns a Publisher.Calls a supplier and emits its value or exception to the incoming SingleObserver.SingleHide<T>Helper utility class to support Single with inner classes.SingleJust<T>SingleLift<T,R> SingleMap<T,R> Turn the signal types of a Single source into a single Notification of equal kind.Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.SingleTakeUntil<T,U> Signals the events of the source Single or signals a CancellationException if the other Publisher signalled first.Measures the time between subscription and the success item emission from the upstream and emits this as aTimedsuccess value.Signals a0Lafter the specified delay.Wraps a Single and exposes it as a Flowable.Wraps a Single and exposes it as an Observable.Makes sure a dispose() call from downstream happens on the specified scheduler.SingleUsing<T,U> SingleZipArray<T,R> SingleZipIterable<T,R>