| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| protected void |
| FlowableMaterialize | back to summary |
|---|---|
| public FlowableMaterialize(Flowable<T> source) | |
| subscribeActual | back to summary |
|---|---|
protected void subscribeActual(Subscriber<? super Notification<T>> s)
| |
| Modifier and Type | Field and Description |
|---|---|
| private static final long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| protected void | onDrop(Notification<T>
the value dropped n)Overrides io. |
| public void | onError(Throwable
the throwable signaled t)Implements org. |
| public void | onNext(T
the element signaled t)Implements org. Publisher in response to requests to Subscription#request(long).
|
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides io. | |
| MaterializeSubscriber | back to summary |
|---|---|
| pack-priv MaterializeSubscriber(Subscriber<? super Notification<T>> downstream) | |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| onDrop | back to summary |
|---|---|
| protected void onDrop(Notification<T> n) Overrides io. Doc from io. Called in case of multiple calls to complete.
| |
| onError | back to summary |
|---|---|
| public void onError(Throwable t) Implements org. Doc from org. Failed terminal state.
No further events will be sent even if | |
| onNext | back to summary |
|---|---|
| public void onNext(T t) Implements org. Doc from org. Data notification sent by the
| |