Uses of Interface
io.reactivex.rxjava3.observers.LambdaConsumerIntrospection
-
Packages that use LambdaConsumerIntrospection Package Description io.reactivex.rxjava3.internal.observers io.reactivex.rxjava3.internal.operators.maybe io.reactivex.rxjava3.internal.subscribers -
-
Uses of LambdaConsumerIntrospection in io.reactivex.rxjava3.internal.observers
Classes in io.reactivex.rxjava3.internal.observers that implement LambdaConsumerIntrospection Modifier and Type Class Description (package private) class
AbstractDisposableAutoRelease
Wraps lambda callbacks and when the upstream terminates or the observer gets disposed, removes itself from aCompositeDisposable
.class
CallbackCompletableObserver
class
ConsumerSingleObserver<T>
class
DisposableAutoReleaseMultiObserver<T>
Wraps lambda callbacks and when the upstream terminates or this (Single | Maybe | Completable) observer gets disposed, removes itself from aCompositeDisposable
.class
DisposableAutoReleaseObserver<T>
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from aCompositeDisposable
.class
EmptyCompletableObserver
class
LambdaObserver<T>
-
Uses of LambdaConsumerIntrospection in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement LambdaConsumerIntrospection Modifier and Type Class Description class
MaybeCallbackObserver<T>
MaybeObserver that delegates the onSuccess, onError and onComplete method calls to callbacks. -
Uses of LambdaConsumerIntrospection in io.reactivex.rxjava3.internal.subscribers
Classes in io.reactivex.rxjava3.internal.subscribers that implement LambdaConsumerIntrospection Modifier and Type Class Description class
BoundedSubscriber<T>
class
DisposableAutoReleaseSubscriber<T>
Wraps lambda callbacks and when the upstream terminates or this subscriber gets disposed, removes itself from aCompositeDisposable
.class
LambdaSubscriber<T>
-