SingleAmb<T> |
|
SingleAmb.AmbSingleObserver<T> |
|
SingleCache<T> |
|
SingleCache.CacheDisposable<T> |
|
SingleContains<T> |
|
SingleCreate<T> |
|
SingleCreate.Emitter<T> |
|
SingleDefer<T> |
|
SingleDelay<T> |
|
SingleDelayWithCompletable<T> |
|
SingleDelayWithCompletable.OtherObserver<T> |
|
SingleDelayWithObservable<T,U> |
|
SingleDelayWithObservable.OtherSubscriber<T,U> |
|
SingleDelayWithPublisher<T,U> |
|
SingleDelayWithPublisher.OtherSubscriber<T,U> |
|
SingleDelayWithSingle<T,U> |
|
SingleDelayWithSingle.OtherObserver<T,U> |
|
SingleDematerialize<T,R> |
Maps the success value of the source to a Notification, then
maps it back to the corresponding signal type.
|
SingleDematerialize.DematerializeObserver<T,R> |
|
SingleDetach<T> |
Breaks the references between the upstream and downstream when the Maybe terminates.
|
SingleDetach.DetachSingleObserver<T> |
|
SingleDoAfterSuccess<T> |
Calls a consumer after pushing the current item to the downstream.
|
SingleDoAfterSuccess.DoAfterObserver<T> |
|
SingleDoAfterTerminate<T> |
Calls an action after pushing the current item or an error to the downstream.
|
SingleDoAfterTerminate.DoAfterTerminateObserver<T> |
|
SingleDoFinally<T> |
Execute an action after an onSuccess, onError or a dispose event.
|
SingleDoFinally.DoFinallyObserver<T> |
|
SingleDoOnDispose<T> |
|
SingleDoOnDispose.DoOnDisposeObserver<T> |
|
SingleDoOnError<T> |
|
SingleDoOnEvent<T> |
|
SingleDoOnLifecycle<T> |
Invokes callbacks upon onSubscribe from upstream and
dispose from downstream.
|
SingleDoOnLifecycle.SingleLifecycleObserver<T> |
|
SingleDoOnSubscribe<T> |
Calls a callback when the upstream calls onSubscribe with a disposable.
|
SingleDoOnSubscribe.DoOnSubscribeSingleObserver<T> |
|
SingleDoOnSuccess<T> |
|
SingleDoOnTerminate<T> |
|
SingleEquals<T> |
|
SingleEquals.InnerObserver<T> |
|
SingleError<T> |
|
SingleFlatMap<T,R> |
|
SingleFlatMap.SingleFlatMapCallback<T,R> |
|
SingleFlatMap.SingleFlatMapCallback.FlatMapSingleObserver<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.
|
SingleFlatMapBiSelector.FlatMapBiMainObserver<T,U,R> |
|
SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver<T,U,R> |
|
SingleFlatMapCompletable<T> |
Maps the success value of the source SingleSource into a Completable.
|
SingleFlatMapCompletable.FlatMapCompletableObserver<T> |
|
SingleFlatMapIterableFlowable<T,R> |
Maps a success value into an Iterable and streams it back as a Flowable.
|
SingleFlatMapIterableFlowable.FlatMapIterableObserver<T,R> |
|
SingleFlatMapIterableObservable<T,R> |
Maps a success value into an Iterable and streams it back as an Observable.
|
SingleFlatMapIterableObservable.FlatMapIterableObserver<T,R> |
|
SingleFlatMapMaybe<T,R> |
|
SingleFlatMapMaybe.FlatMapMaybeObserver<R> |
|
SingleFlatMapMaybe.FlatMapSingleObserver<T,R> |
|
SingleFlatMapNotification<T,R> |
Maps a value into a SingleSource and relays its signal.
|
SingleFlatMapNotification.FlatMapSingleObserver<T,R> |
|
SingleFlatMapPublisher<T,R> |
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.
|
SingleFlatMapPublisher.SingleFlatMapPublisherObserver<S,T> |
|
SingleFromCallable<T> |
|
SingleFromPublisher<T> |
|
SingleFromPublisher.ToSingleObserver<T> |
|
SingleFromSupplier<T> |
Calls a supplier and emits its value or exception to the incoming SingleObserver.
|
SingleFromUnsafeSource<T> |
|
SingleHide<T> |
|
SingleHide.HideSingleObserver<T> |
|
SingleInternalHelper |
Helper utility class to support Single with inner classes.
|
SingleInternalHelper.ToFlowableIterable<T> |
|
SingleInternalHelper.ToFlowableIterator<T> |
|
SingleJust<T> |
|
SingleLift<T,R> |
|
SingleMap<T,R> |
|
SingleMap.MapSingleObserver<T,R> |
|
SingleMaterialize<T> |
Turn the signal types of a Single source into a single Notification of
equal kind.
|
SingleNever |
|
SingleObserveOn<T> |
|
SingleObserveOn.ObserveOnSingleObserver<T> |
|
SingleOnErrorComplete<T> |
Emits an onComplete if the source emits an onError and the predicate returns true for
that Throwable.
|
SingleOnErrorReturn<T> |
|
SingleResumeNext<T> |
|
SingleResumeNext.ResumeMainSingleObserver<T> |
|
SingleSubscribeOn<T> |
|
SingleSubscribeOn.SubscribeOnObserver<T> |
|
SingleTakeUntil<T,U> |
Signals the events of the source Single or signals a CancellationException if the
other Publisher signalled first.
|
SingleTakeUntil.TakeUntilMainObserver<T> |
|
SingleTakeUntil.TakeUntilOtherSubscriber |
|
SingleTimeInterval<T> |
Measures the time between subscription and the success item emission
from the upstream and emits this as a Timed success value.
|
SingleTimeInterval.TimeIntervalSingleObserver<T> |
|
SingleTimeout<T> |
|
SingleTimeout.TimeoutMainObserver<T> |
|
SingleTimeout.TimeoutMainObserver.TimeoutFallbackObserver<T> |
|
SingleTimer |
Signals a 0L after the specified delay.
|
SingleTimer.TimerDisposable |
|
SingleToFlowable<T> |
Wraps a Single and exposes it as a Flowable.
|
SingleToFlowable.SingleToFlowableObserver<T> |
|
SingleToObservable<T> |
Wraps a Single and exposes it as an Observable.
|
SingleToObservable.SingleToObservableObserver<T> |
|
SingleUnsubscribeOn<T> |
Makes sure a dispose() call from downstream happens on the specified scheduler.
|
SingleUnsubscribeOn.UnsubscribeOnSingleObserver<T> |
|
SingleUsing<T,U> |
|
SingleUsing.UsingSingleObserver<T,U> |
|
SingleZipArray<T,R> |
|
SingleZipArray.ZipCoordinator<T,R> |
|
SingleZipArray.ZipSingleObserver<T> |
|
SingleZipIterable<T,R> |
|