Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
Modifier and Type | Method and Description |
---|---|
FlowableEmitter<T> |
FlowableEmitter.serialize()
Ensures that calls to onNext, onError and onComplete are properly serialized.
|
Modifier and Type | Method and Description |
---|---|
void |
FlowableOnSubscribe.subscribe(FlowableEmitter<T> emitter)
Called for each Subscriber that subscribes.
|
Copyright © 2019. All rights reserved.