| Modifier and Type | Class and Description |
|---|---|
| pack-priv static class | |
| pack-priv static class | |
| pack-priv static class | |
| pack-priv static interface | |
| pack-priv static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Publisher | |
| pack-priv final Scheduler | |
| pack-priv final long | |
| pack-priv final TimeUnit |
| Access | Constructor and Description |
|---|---|
| public | FlowableTimeoutTimed(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Publisher<? extends T> other)
|
| Modifier and Type | Method and Description |
|---|---|
| protected void | subscribeActual(Subscriber<? super T>
the incoming Subscriber, never null s)Implements abstract io. Subscribers.
|
| other | back to summary |
|---|---|
| pack-priv final Publisher<? extends T> other | |
| scheduler | back to summary |
|---|---|
| pack-priv final Scheduler scheduler | |
| timeout | back to summary |
|---|---|
| pack-priv final long timeout | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| FlowableTimeoutTimed | back to summary |
|---|---|
| public FlowableTimeoutTimed(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Publisher<? extends T> other) | |
| subscribeActual | back to summary |
|---|---|
| protected void subscribeActual(Subscriber<? super T> s) Implements abstract io. Doc from io. Operator implementations (both source and intermediate) should implement this method that
performs the necessary business logic and handles the incoming There is no need to call any of the plugin hooks on the current
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final SubscriptionArbiter | |
| pack-priv final Subscriber |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| 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).
|
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Implements io. onNext(Object) is established before
calling Subscription#request(long).
|
| arbiter | back to summary |
|---|---|
| pack-priv final SubscriptionArbiter arbiter | |
| downstream | back to summary |
|---|---|
| pack-priv final Subscriber<? super T> downstream | |
| FallbackSubscriber | back to summary |
|---|---|
| pack-priv FallbackSubscriber(Subscriber<? super T> actual, SubscriptionArbiter arbiter) | |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| 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
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Implements io. Doc from io. Implementors of this method should make sure everything that needs
to be visible in
No data will start flowing until
It is the responsibility of this
The
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv long | |
| pack-priv final Subscriber | |
| pack-priv Publisher | |
| pack-priv final AtomicLong | |
| private static final long | |
| pack-priv final SequentialDisposable | |
| pack-priv final long | |
| pack-priv final TimeUnit | |
| pack-priv final AtomicReference | |
| pack-priv final Scheduler. |
| Access | Constructor and Description |
|---|---|
| pack-priv | TimeoutFallbackSubscriber(Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
| public void | cancel()
Overrides io. Implements org. Publisher to stop sending data and clean up resources.
|
| public void | |
| 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).
|
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Implements io. onNext(Object) is established before
calling Subscription#request(long).
|
| public void | |
| pack-priv void |
| consumed | back to summary |
|---|---|
| pack-priv long consumed | |
| downstream | back to summary |
|---|---|
| pack-priv final Subscriber<? super T> downstream | |
| fallback | back to summary |
|---|---|
| pack-priv Publisher<? extends T> fallback | |
| index | back to summary |
|---|---|
| pack-priv final AtomicLong index | |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides io. | |
| task | back to summary |
|---|---|
| pack-priv final SequentialDisposable task | |
| timeout | back to summary |
|---|---|
| pack-priv final long timeout | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| upstream | back to summary |
|---|---|
| pack-priv final AtomicReference<Subscription> upstream | |
| worker | back to summary |
|---|---|
| pack-priv final Scheduler. | |
| TimeoutFallbackSubscriber | back to summary |
|---|---|
| pack-priv TimeoutFallbackSubscriber(Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler. | |
| cancel | back to summary |
|---|---|
| public void cancel() Overrides io. Implements org. Doc from org. Request the Data may still be sent to meet previously signalled demand after calling cancel.
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| 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
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Implements io. Doc from io. Implementors of this method should make sure everything that needs
to be visible in
No data will start flowing until
It is the responsibility of this
The
| |
| onTimeout | back to summary |
|---|---|
| public void onTimeout(long idx) Implements io.
| |
| startTimeout | back to summary |
|---|---|
| pack-priv void startTimeout(long nextIndex) | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final Subscriber | |
| pack-priv final AtomicLong | |
| private static final long | |
| pack-priv final SequentialDisposable | |
| pack-priv final long | |
| pack-priv final TimeUnit | |
| pack-priv final AtomicReference | |
| pack-priv final Scheduler. |
| Access | Constructor and Description |
|---|---|
| pack-priv | TimeoutSubscriber(Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.
|
| Modifier and Type | Method and Description |
|---|---|
| public void | cancel()
Implements org. Publisher to stop sending data and clean up resources.
|
| public void | |
| 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).
|
| public void | onSubscribe(Subscription
the s)Subscription that allows requesting data via Subscription#request(long)Implements io. onNext(Object) is established before
calling Subscription#request(long).
|
| public void | |
| public void | request(long
the strictly positive number of elements to requests to the upstream n)PublisherImplements org. Publisher until demand is signaled via this method.
|
| pack-priv void |
| downstream | back to summary |
|---|---|
| pack-priv final Subscriber<? super T> downstream | |
| requested | back to summary |
|---|---|
| pack-priv final AtomicLong requested | |
| serialVersionUID | back to summary |
|---|---|
| private static final long serialVersionUID Hides java. | |
| task | back to summary |
|---|---|
| pack-priv final SequentialDisposable task | |
| timeout | back to summary |
|---|---|
| pack-priv final long timeout | |
| unit | back to summary |
|---|---|
| pack-priv final TimeUnit unit | |
| upstream | back to summary |
|---|---|
| pack-priv final AtomicReference<Subscription> upstream | |
| worker | back to summary |
|---|---|
| pack-priv final Scheduler. | |
| TimeoutSubscriber | back to summary |
|---|---|
| pack-priv TimeoutSubscriber(Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler. | |
| cancel | back to summary |
|---|---|
| public void cancel() Implements org. Doc from org. Request the Data may still be sent to meet previously signalled demand after calling cancel.
| |
| onComplete | back to summary |
|---|---|
| public void onComplete() Implements org. Doc from org. Successful terminal state.
No further events will be sent even if
| |
| 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
| |
| onSubscribe | back to summary |
|---|---|
| public void onSubscribe(Subscription s) Implements io. Doc from io. Implementors of this method should make sure everything that needs
to be visible in
No data will start flowing until
It is the responsibility of this
The
| |
| onTimeout | back to summary |
|---|---|
| public void onTimeout(long idx) Implements io.
| |
| request | back to summary |
|---|---|
| public void request(long n) Implements org. Doc from org. No events will be sent by a
It can be called however often and whenever needed—but if the outstanding cumulative demand ever becomes Long.MAX_VALUE or more,
it may be treated by the
Whatever has been requested can be sent by the
A | |
| startTimeout | back to summary |
|---|---|
| pack-priv void startTimeout(long nextIndex) | |
| Modifier and Type | Method and Description |
|---|---|
| public void |
| onTimeout | back to summary |
|---|---|
| public void onTimeout(long idx) | |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final long | |
| pack-priv final FlowableTimeoutTimed. |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public void |
| idx | back to summary |
|---|---|
| pack-priv final long idx | |
| parent | back to summary |
|---|---|
| pack-priv final FlowableTimeoutTimed. | |
| TimeoutTask | back to summary |
|---|---|
| pack-priv TimeoutTask(long idx, FlowableTimeoutTimed. | |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |