Class FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>
,org.reactivestreams.Subscriber<T>
- Enclosing class:
FlowableSwitchIfEmpty<T>
static final class FlowableSwitchIfEmpty.SwitchIfEmptySubscriber<T>
extends Object
implements FlowableSubscriber<T>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final SubscriptionArbiter
(package private) final org.reactivestreams.Subscriber
<? super T> (package private) boolean
(package private) final org.reactivestreams.Publisher
<? extends T> -
Constructor Summary
ConstructorsConstructorDescriptionSwitchIfEmptySubscriber
(org.reactivestreams.Subscriber<? super T> actual, org.reactivestreams.Publisher<? extends T> other) -
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
-
other
-
arbiter
-
empty
boolean empty
-
-
Constructor Details
-
SwitchIfEmptySubscriber
-
-
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>
-