| 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 © 2025. All rights reserved.