Uses of Interface
io.reactivex.rxjava3.core.MaybeObserver
Packages that use MaybeObserver
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Default wrappers and implementations for observer-based consumer classes and interfaces,
including disposable and resource-tracking variants and
the
TestObserver
that allows unit testing
Observable
-, Single
-,
Maybe
- and Completable
-based flows.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.Classes representing so-called hot sources, aka subjects, that implement a base reactive class and
the respective consumer type at once to allow forms of multicasting events to multiple
consumers as well as consuming another base reactive type of their kind.
-
Uses of MaybeObserver in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with type parameters of type MaybeObserverModifier and TypeMethodDescriptionfinal <@NonNull E extends MaybeObserver<? super @NonNull T>>
EMaybe.subscribeWith
(@NonNull E observer) Subscribes a givenMaybeObserver
(subclass) to thisMaybe
and returns the givenMaybeObserver
as is.Methods in io.reactivex.rxjava3.core that return MaybeObserverModifier and TypeMethodDescription@NonNull MaybeObserver
<? super Upstream> MaybeOperator.apply
(@NonNull MaybeObserver<? super @NonNull Downstream> observer) Applies a function to the childMaybeObserver
and returns a new parentMaybeObserver
.Methods in io.reactivex.rxjava3.core with parameters of type MaybeObserverModifier and TypeMethodDescription@NonNull MaybeObserver
<? super Upstream> MaybeOperator.apply
(@NonNull MaybeObserver<? super @NonNull Downstream> observer) Applies a function to the childMaybeObserver
and returns a new parentMaybeObserver
.final void
Maybe.blockingSubscribe
(@NonNull MaybeObserver<? super @NonNull T> observer) Subscribes to the currentMaybe
and calls the appropriateMaybeObserver
method on the current thread.final void
Maybe.safeSubscribe
(@NonNull MaybeObserver<? super @NonNull T> observer) Wraps the givenMaybeObserver
, catches anyRuntimeException
s thrown by itsonSubscribe(Disposable)
,onSuccess(Object)
,onError(Throwable)
oronComplete()
methods and routes those to the global error handler viaRxJavaPlugins.onError(Throwable)
.final void
Maybe.subscribe
(@NonNull MaybeObserver<? super @NonNull T> observer) void
MaybeSource.subscribe
(@NonNull MaybeObserver<? super @NonNull T> observer) Subscribes the givenMaybeObserver
to thisMaybeSource
instance.protected abstract void
Maybe.subscribeActual
(@NonNull MaybeObserver<? super @NonNull T> observer) Implement this method in subclasses to handle the incomingMaybeObserver
s. -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.disposables
Methods in io.reactivex.rxjava3.internal.disposables with parameters of type MaybeObserverModifier and TypeMethodDescriptionstatic void
EmptyDisposable.complete
(MaybeObserver<?> observer) static void
EmptyDisposable.error
(Throwable e, MaybeObserver<?> observer) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.jdk8
Classes in io.reactivex.rxjava3.internal.jdk8 that implement MaybeObserverModifier and TypeClassDescriptionfinal class
Class that extends CompletableFuture and converts multiple types of reactive consumers and their signals into completion signals.(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.jdk8 declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> MaybeFromCompletionStage.CompletionStageHandler.downstream
(package private) final MaybeObserver
<? super R> MaybeMapOptional.MapOptionalMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> SingleMapOptional.MapOptionalSingleObserver.downstream
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
MaybeFromCompletionStage.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeMapOptional.subscribeActual
(MaybeObserver<? super R> observer) protected void
SingleMapOptional.subscribeActual
(MaybeObserver<? super R> observer) Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type MaybeObserverModifierConstructorDescription(package private)
CompletionStageHandler
(MaybeObserver<? super T> downstream, FlowableFromCompletionStage.BiConsumerAtomicReference<T> whenReference) (package private)
MapOptionalMaybeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
MapOptionalSingleObserver
(MaybeObserver<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement MaybeObserverModifier and TypeClassDescriptionfinal class
Blocks until the upstream terminates and dispatches the outcome to the actual observer.final class
A combined Observer that awaits the success or error signal via a CountDownLatch.final class
Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from aCompositeDisposable
.final class
An Observer + Future that expects exactly one upstream value and provides it via the (blocking) Future API.final class
Wraps anotherMaybeObserver
and catches exceptions thrown by itsonSubscribe
,onSuccess
,onError
oronComplete
methods despite the protocol forbids it.Fields in io.reactivex.rxjava3.internal.observers declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> SafeMaybeObserver.downstream
Methods in io.reactivex.rxjava3.internal.observers with parameters of type MaybeObserverModifier and TypeMethodDescriptionvoid
BlockingDisposableMultiObserver.blockingConsume
(MaybeObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.observers with parameters of type MaybeObserver -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> CompletableOnErrorReturn.OnErrorReturnMaybeObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.completable with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
CompletableOnErrorReturn.subscribeActual
(MaybeObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type MaybeObserverModifierConstructorDescription(package private)
OnErrorReturnMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends T> itemSupplier) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement MaybeObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> FlowableElementAtMaybe.ElementAtSubscriber.downstream
(package private) final MaybeObserver
<? super T> FlowableLastMaybe.LastSubscriber.downstream
(package private) final MaybeObserver
<? super T> FlowableReduceMaybe.ReduceSubscriber.downstream
(package private) final MaybeObserver
<? super T> FlowableSingleMaybe.SingleElementSubscriber.downstream
Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
FlowableElementAtMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
FlowableElementAtMaybePublisher.subscribeActual
(MaybeObserver<? super T> observer) protected void
FlowableLastMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
FlowableReduceMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
FlowableSingleMaybe.subscribeActual
(MaybeObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type MaybeObserverModifierConstructorDescription(package private)
ElementAtSubscriber
(MaybeObserver<? super T> actual, long index) (package private)
LastSubscriber
(MaybeObserver<? super T> downstream) (package private)
ReduceSubscriber
(MaybeObserver<? super T> actual, BiFunction<T, T, T> reducer) (package private)
SingleElementSubscriber
(MaybeObserver<? super T> downstream) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement MaybeObserverModifier and TypeClassDescription(package private) static final class
final class
MaybeCache<T>
Consumes the source once and replays its signal to any current or future MaybeObservers.final class
MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> MaybeAmb.AmbMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeCache.CacheDisposable.downstream
(package private) final MaybeObserver
<? super T> MaybeCreate.Emitter.downstream
(package private) final MaybeObserver
<? super T> MaybeDelay.DelayMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDelayOtherPublisher.OtherSubscriber.downstream
(package private) final MaybeObserver
<? super T> MaybeDelaySubscriptionOtherPublisher.DelayMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDelayWithCompletable.DelayWithMainObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDelayWithCompletable.OtherObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeDematerialize.DematerializeObserver.downstream
(package private) MaybeObserver
<? super T> MaybeDetach.DetachMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDoAfterSuccess.DoAfterObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDoFinally.DoFinallyObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDoOnEvent.DoOnEventMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDoOnLifecycle.MaybeLifecycleObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeDoOnTerminate.DoOnTerminate.downstream
(package private) final MaybeObserver
<? super T> MaybeFilter.FilterMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeFilterSingle.FilterMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeFlatMapNotification.FlatMapMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeFlatMapSingle.FlatMapMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeFlatMapSingle.FlatMapSingleObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeFlatten.FlatMapMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeFromCompletable.FromCompletableObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeFromSingle.FromSingleObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeHide.HideMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeIgnoreElement.IgnoreMaybeObserver.downstream
(package private) final MaybeObserver
<? super Boolean> MaybeIsEmpty.IsEmptyMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeMap.MapMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeObserveOn.ObserveOnMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeOnErrorComplete.OnErrorCompleteMultiObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeOnErrorNext.OnErrorNextMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeOnErrorNext.OnErrorNextMaybeObserver.NextMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeOnErrorReturn.OnErrorReturnMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybePeek.MaybePeekObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeSubscribeOn.SubscribeOnMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeSwitchIfEmpty.SwitchIfEmptyMaybeObserver.OtherMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTakeUntilMaybe.TakeUntilMainMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTakeUntilPublisher.TakeUntilMainMaybeObserver.downstream
(package private) final MaybeObserver
<? super Timed<T>> MaybeTimeInterval.TimeIntervalMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTimeoutMaybe.TimeoutFallbackMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTimeoutMaybe.TimeoutMainMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTimeoutPublisher.TimeoutFallbackMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeTimeoutPublisher.TimeoutMainMaybeObserver.downstream
(package private) final MaybeObserver
<? super Long> MaybeTimer.TimerDisposable.downstream
(package private) final MaybeObserver
<? super T> MaybeUnsubscribeOn.UnsubscribeOnMaybeObserver.downstream
(package private) final MaybeObserver
<? super T> MaybeUsing.UsingObserver.downstream
(package private) final MaybeObserver
<? super R> MaybeZipArray.ZipCoordinator.downstream
(package private) final MaybeObserver
<? super T> MaybeSubscribeOn.SubscribeTask.observer
Methods in io.reactivex.rxjava3.internal.operators.maybe that return MaybeObserverModifier and TypeMethodDescriptionstatic <T> MaybeObserver
<T> Creates aMaybeObserver
wrapper around aObserver
.Methods in io.reactivex.rxjava3.internal.operators.maybe with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
MaybeAmb.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeCache.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeCreate.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDefer.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDelay.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDelayOtherPublisher.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDelaySubscriptionOtherPublisher.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDelayWithCompletable.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDematerialize.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeDetach.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDoAfterSuccess.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDoFinally.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDoOnEvent.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDoOnLifecycle.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeDoOnTerminate.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeEmpty.subscribeActual
(MaybeObserver<? super Object> observer) protected void
MaybeError.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeErrorCallable.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFilter.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFilterSingle.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFlatMapBiSelector.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeFlatMapNotification.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeFlatMapSingle.subscribeActual
(MaybeObserver<? super R> downstream) protected void
MaybeFlatten.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeFromAction.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromCallable.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromCompletable.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromFuture.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromRunnable.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromSingle.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeFromSupplier.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeHide.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeIgnoreElement.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeIsEmpty.subscribeActual
(MaybeObserver<? super Boolean> observer) protected void
MaybeJust.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeLift.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeMap.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeNever.subscribeActual
(MaybeObserver<? super Object> observer) protected void
MaybeObserveOn.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeOnErrorComplete.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeOnErrorNext.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeOnErrorReturn.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybePeek.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeSubscribeOn.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeSwitchIfEmpty.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeTakeUntilMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeTakeUntilPublisher.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeTimeInterval.subscribeActual
(@NonNull MaybeObserver<? super @NonNull Timed<T>> observer) protected void
MaybeTimeoutMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeTimeoutPublisher.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeTimer.subscribeActual
(MaybeObserver<? super Long> observer) protected void
MaybeUnsafeCreate.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeUnsubscribeOn.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeUsing.subscribeActual
(MaybeObserver<? super T> observer) protected void
MaybeZipArray.subscribeActual
(MaybeObserver<? super R> observer) protected void
MaybeZipIterable.subscribeActual
(MaybeObserver<? super R> observer) Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type MaybeObserverModifierConstructorDescription(package private)
AmbMaybeObserver
(MaybeObserver<? super T> downstream, CompositeDisposable set, AtomicBoolean winner) (package private)
CacheDisposable
(MaybeObserver<? super T> actual, MaybeCache<T> parent) (package private)
DelayMaybeObserver
(MaybeObserver<? super T> actual, long delay, TimeUnit unit, Scheduler scheduler, boolean delayError) (package private)
DelayMaybeObserver
(MaybeObserver<? super T> actual, org.reactivestreams.Publisher<U> otherSource) (package private)
DelayMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
DelayWithMainObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super T> downstream) (package private)
DematerializeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector) (package private)
DetachMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
DoAfterObserver
(MaybeObserver<? super T> actual, Consumer<? super T> onAfterSuccess) (package private)
DoFinallyObserver
(MaybeObserver<? super T> actual, Action onFinally) (package private)
DoOnEventMaybeObserver
(MaybeObserver<? super T> actual, BiConsumer<? super T, ? super Throwable> onEvent) (package private)
DoOnTerminate
(MaybeObserver<? super T> observer) (package private)
Emitter
(MaybeObserver<? super T> downstream) (package private)
FilterMaybeObserver
(MaybeObserver<? super T> actual, Predicate<? super T> predicate) (package private)
FilterMaybeObserver
(MaybeObserver<? super T> actual, Predicate<? super T> predicate) (package private)
FlatMapBiMainObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) (package private)
FlatMapSingleObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super R> downstream) (package private)
FromCompletableObserver
(MaybeObserver<? super T> downstream) (package private)
FromSingleObserver
(MaybeObserver<? super T> downstream) (package private)
HideMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
IgnoreMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
InnerObserver
(MaybeObserver<? super R> actual, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
IsEmptyMaybeObserver
(MaybeObserver<? super Boolean> downstream) (package private)
MapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends R> mapper) (package private)
MaybeLifecycleObserver
(MaybeObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) (package private)
MaybePeekObserver
(MaybeObserver<? super T> actual, MaybePeek<T> parent) (package private)
NextMaybeObserver
(MaybeObserver<? super T> actual, AtomicReference<Disposable> d) (package private)
ObserveOnMaybeObserver
(MaybeObserver<? super T> actual, Scheduler scheduler) OnErrorCompleteMultiObserver
(MaybeObserver<? super T> actual, Predicate<? super Throwable> predicate) (package private)
OnErrorNextMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) (package private)
OnErrorReturnMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier) (package private)
OtherMaybeObserver
(MaybeObserver<? super T> actual, AtomicReference<Disposable> parent) (package private)
OtherObserver
(MaybeObserver<? super T> actual, MaybeSource<T> source) (package private)
OtherSubscriber
(MaybeObserver<? super T> downstream) (package private)
OtherSubscriber
(MaybeObserver<? super T> actual, MaybeSource<T> source) (package private)
SubscribeOnMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
SubscribeTask
(MaybeObserver<? super T> observer, MaybeSource<T> source) (package private)
SwitchIfEmptyMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> other) (package private)
TakeUntilMainMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
TakeUntilMainMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
TimeIntervalMaybeObserver
(MaybeObserver<? super Timed<T>> downstream, TimeUnit unit, Scheduler scheduler, boolean start) (package private)
TimeoutFallbackMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
TimeoutFallbackMaybeObserver
(MaybeObserver<? super T> downstream) (package private)
TimeoutMainMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> fallback) (package private)
TimeoutMainMaybeObserver
(MaybeObserver<? super T> actual, MaybeSource<? extends T> fallback) (package private)
TimerDisposable
(MaybeObserver<? super Long> downstream) (package private)
UnsubscribeOnMaybeObserver
(MaybeObserver<? super T> actual, Scheduler scheduler) (package private)
UsingObserver
(MaybeObserver<? super T> actual, D resource, Consumer<? super D> disposer, boolean eager) (package private)
ZipCoordinator
(MaybeObserver<? super R> observer, int n, Function<? super Object[], ? extends R> zipper) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.mixed
Classes in io.reactivex.rxjava3.internal.operators.mixed that implement MaybeObserverModifier and TypeClassDescription(package private) static final class
(package private) static final class
final class
A consumer that implements the consumer types of Maybe, Single and Completable and turns their signals into Notifications for a SingleObserver.(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
-
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement MaybeObserverModifier and TypeClassDescription(package private) static final class
(package private) final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> ObservableElementAtMaybe.ElementAtObserver.downstream
(package private) final MaybeObserver
<? super T> ObservableLastMaybe.LastObserver.downstream
(package private) final MaybeObserver
<? super T> ObservableReduceMaybe.ReduceObserver.downstream
(package private) final MaybeObserver
<? super T> ObservableSingleMaybe.SingleElementObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type MaybeObserverModifier and TypeMethodDescriptionvoid
ObservableElementAtMaybe.subscribeActual
(MaybeObserver<? super T> t) protected void
ObservableLastMaybe.subscribeActual
(MaybeObserver<? super T> observer) protected void
ObservableReduceMaybe.subscribeActual
(MaybeObserver<? super T> observer) void
ObservableSingleMaybe.subscribeActual
(MaybeObserver<? super T> t) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type MaybeObserverModifierConstructorDescription(package private)
ElementAtObserver
(MaybeObserver<? super T> actual, long index) (package private)
LastObserver
(MaybeObserver<? super T> downstream) (package private)
ReduceObserver
(MaybeObserver<? super T> observer, BiFunction<T, T, T> reducer) (package private)
SingleElementObserver
(MaybeObserver<? super T> downstream) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement MaybeObserverModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super R> SingleDematerialize.DematerializeObserver.downstream
(package private) final MaybeObserver
<? super R> SingleFlatMapMaybe.FlatMapMaybeObserver.downstream
(package private) final MaybeObserver
<? super R> SingleFlatMapMaybe.FlatMapSingleObserver.downstream
Methods in io.reactivex.rxjava3.internal.operators.single with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
SingleDematerialize.subscribeActual
(MaybeObserver<? super R> observer) protected void
SingleFlatMapMaybe.subscribeActual
(MaybeObserver<? super R> downstream) protected void
SingleOnErrorComplete.subscribeActual
(MaybeObserver<? super T> observer) Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type MaybeObserverModifierConstructorDescription(package private)
DematerializeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector) (package private)
FlatMapMaybeObserver
(AtomicReference<Disposable> parent, MaybeObserver<? super R> downstream) (package private)
FlatMapSingleObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) -
Uses of MaybeObserver in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement MaybeObserverModifier and TypeClassDescriptionenum
Singleton implementing many interfaces as empty.Methods in io.reactivex.rxjava3.internal.util with parameters of type MaybeObserverModifier and TypeMethodDescriptionvoid
AtomicThrowable.tryTerminateConsumer
(MaybeObserver<?> consumer) Tries to terminate this atomic throwable (by swapping in the TERMINATED indicator) and notifies the consumer if there was no error (onComplete) or there was a non-null, non-indicator exception contained before (onError). -
Uses of MaybeObserver in io.reactivex.rxjava3.observers
Classes in io.reactivex.rxjava3.observers that implement MaybeObserverModifier and TypeClassDescriptionclass
An abstractMaybeObserver
that allows asynchronous cancellation by implementingDisposable
.class
An abstractMaybeObserver
that allows asynchronous cancellation of its subscription and associated resources.class
TestObserver<T>
AnObserver
,MaybeObserver
,SingleObserver
andCompletableObserver
composite that can record events fromObservable
s,Maybe
s,Single
s andCompletable
s and allows making assertions about them. -
Uses of MaybeObserver in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins with type parameters of type MaybeObserverModifier and TypeFieldDescription(package private) static @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.onMaybeSubscribe
(package private) static @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.onMaybeSubscribe
Methods in io.reactivex.rxjava3.plugins that return MaybeObserverModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull MaybeObserver<? super T> RxJavaPlugins.onSubscribe
(@NonNull Maybe<@NonNull T> source, @NonNull MaybeObserver<? super @NonNull T> observer) Calls the associated hook function.Methods in io.reactivex.rxjava3.plugins that return types with arguments of type MaybeObserverModifier and TypeMethodDescriptionstatic @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type MaybeObserverModifier and TypeMethodDescriptionstatic <@NonNull T>
@NonNull MaybeObserver<? super T> RxJavaPlugins.onSubscribe
(@NonNull Maybe<@NonNull T> source, @NonNull MaybeObserver<? super @NonNull T> observer) Calls the associated hook function.Method parameters in io.reactivex.rxjava3.plugins with type arguments of type MaybeObserverModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setOnMaybeSubscribe
(@Nullable BiFunction<? super Maybe, @NonNull MaybeObserver, @NonNull ? extends MaybeObserver> onMaybeSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnMaybeSubscribe
(@Nullable BiFunction<? super Maybe, @NonNull MaybeObserver, @NonNull ? extends MaybeObserver> onMaybeSubscribe) Sets the specific hook function. -
Uses of MaybeObserver in io.reactivex.rxjava3.subjects
Classes in io.reactivex.rxjava3.subjects that implement MaybeObserverModifier and TypeClassDescriptionfinal class
MaybeSubject<T>
Represents a hot Maybe-like source and consumer of events similar to Subjects.Fields in io.reactivex.rxjava3.subjects declared as MaybeObserverModifier and TypeFieldDescription(package private) final MaybeObserver
<? super T> MaybeSubject.MaybeDisposable.downstream
Methods in io.reactivex.rxjava3.subjects with parameters of type MaybeObserverModifier and TypeMethodDescriptionprotected void
MaybeSubject.subscribeActual
(MaybeObserver<? super T> observer) Constructors in io.reactivex.rxjava3.subjects with parameters of type MaybeObserverModifierConstructorDescription(package private)
MaybeDisposable
(MaybeObserver<? super T> actual, MaybeSubject<T> parent)