Class FlowableTimeoutTimed.FallbackSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableTimeoutTimed.FallbackSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,org.reactivestreams.Subscriber<T>
- Enclosing class:
FlowableTimeoutTimed<T>
static final class FlowableTimeoutTimed.FallbackSubscriber<T>
extends Object
implements FlowableSubscriber<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final SubscriptionArbiter
(package private) final org.reactivestreams.Subscriber
<? super T> -
Constructor Summary
ConstructorsConstructorDescriptionFallbackSubscriber
(org.reactivestreams.Subscriber<? super T> actual, SubscriptionArbiter arbiter) -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
void
void
onSubscribe
(org.reactivestreams.Subscription s) Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
.
-
Field Details
-
downstream
-
arbiter
-
-
Constructor Details
-
FallbackSubscriber
FallbackSubscriber(org.reactivestreams.Subscriber<? super T> actual, SubscriptionArbiter arbiter)
-
-
Method Details
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription s) Description copied from interface:FlowableSubscriber
Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
. In practice this means no initialization should happen after therequest()
call and additional behavior is thread safe in respect toonNext
.- Specified by:
onSubscribe
in interfaceFlowableSubscriber<T>
- Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<T>
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<T>
-