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 upononSubscribe
from upstream anddispose
from 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 aTimed
success value.Signals a0L
after 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>