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.
|
Modifier and Type | Method and Description |
---|---|
void |
Completable.subscribe(CompletableSubscriber s)
Subscribes the given CompletableSubscriber to this Completable instance
and handles exceptions thrown by its onXXX methods.
|
void |
Completable.unsafeSubscribe(CompletableSubscriber s)
Subscribes the given CompletableSubscriber to this Completable instance.
|
Modifier and Type | Method and Description |
---|---|
void |
OnSubscribeOnAssemblyCompletable.call(CompletableSubscriber t) |
void |
CompletableOnSubscribeTimeout.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeMergeIterable.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeMergeDelayErrorIterable.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeMergeDelayErrorArray.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeMergeArray.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeMerge.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeConcatIterable.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeConcatArray.call(CompletableSubscriber s) |
void |
CompletableOnSubscribeConcat.call(CompletableSubscriber s) |
void |
CompletableFromEmitter.call(CompletableSubscriber t) |
void |
CompletableFlatMapSingleToCompletable.call(CompletableSubscriber t) |
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(CompletableSubscriber actual) |
Copyright © 2018. All rights reserved.