Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.observers |
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Class and 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.
|
Constructor and Description |
---|
SafeCompletableSubscriber(Completable.CompletableSubscriber actual) |
Copyright © 2024. All rights reserved.