Uses of Interface
rx.Completable.CompletableSubscriber
-
Packages that use Completable.CompletableSubscriber Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.observers Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks. -
-
Uses of Completable.CompletableSubscriber in rx
Methods in rx with parameters of type Completable.CompletableSubscriber Modifier and Type Method Description void
Completable. subscribe(Completable.CompletableSubscriber s)
Subscribes the given CompletableSubscriber to this Completable instance and handles exceptions thrown by its onXXX methods.void
Completable. unsafeSubscribe(Completable.CompletableSubscriber s)
Subscribes the given CompletableSubscriber to this Completable instance. -
Uses of Completable.CompletableSubscriber in rx.internal.operators
Classes in rx.internal.operators that implement Completable.CompletableSubscriber Modifier and Type Class Description (package private) class
CompletableOnSubscribeConcat.CompletableConcatSubscriber.ConcatInnerSubscriber
(package private) static class
CompletableOnSubscribeConcatArray.ConcatInnerSubscriber
(package private) static class
CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber
(package private) static class
OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber
Fields in rx.internal.operators declared as Completable.CompletableSubscriber Modifier and Type Field Description (package private) Completable.CompletableSubscriber
CompletableOnSubscribeConcat.CompletableConcatSubscriber. actual
(package private) Completable.CompletableSubscriber
CompletableOnSubscribeConcatArray.ConcatInnerSubscriber. actual
(package private) Completable.CompletableSubscriber
CompletableOnSubscribeConcatIterable.ConcatInnerSubscriber. actual
(package private) Completable.CompletableSubscriber
CompletableOnSubscribeMerge.CompletableMergeSubscriber. actual
(package private) Completable.CompletableSubscriber
OnSubscribeOnAssemblyCompletable.OnAssemblyCompletableSubscriber. actual
Methods in rx.internal.operators with parameters of type Completable.CompletableSubscriber Modifier and Type Method Description void
CompletableOnSubscribeConcat. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeConcatArray. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeConcatIterable. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeMerge. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeMergeArray. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeMergeDelayErrorArray. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeMergeDelayErrorIterable. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeMergeIterable. call(Completable.CompletableSubscriber s)
void
CompletableOnSubscribeTimeout. call(Completable.CompletableSubscriber s)
void
OnSubscribeOnAssemblyCompletable. call(Completable.CompletableSubscriber t)
Constructors in rx.internal.operators with parameters of type Completable.CompletableSubscriber Constructor Description CompletableConcatSubscriber(Completable.CompletableSubscriber actual, int prefetch)
CompletableMergeSubscriber(Completable.CompletableSubscriber actual, int maxConcurrency, boolean delayErrors)
ConcatInnerSubscriber(Completable.CompletableSubscriber actual, Completable[] sources)
ConcatInnerSubscriber(Completable.CompletableSubscriber actual, java.util.Iterator<? extends Completable> sources)
OnAssemblyCompletableSubscriber(Completable.CompletableSubscriber actual, java.lang.String stacktrace)
-
Uses of Completable.CompletableSubscriber in rx.observers
Classes in rx.observers that implement Completable.CompletableSubscriber Modifier and Type Class Description class
AsyncCompletableSubscriber
An abstract base class for CompletableSubscriber implementations that want to expose an unsubscription capability.class
SafeCompletableSubscriber
Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.Fields in rx.observers declared as Completable.CompletableSubscriber Modifier and Type Field Description (package private) Completable.CompletableSubscriber
SafeCompletableSubscriber. actual
Constructors in rx.observers with parameters of type Completable.CompletableSubscriber Constructor Description SafeCompletableSubscriber(Completable.CompletableSubscriber actual)
-