Class FlowableSamplePublisher.SamplerSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableSamplePublisher.SamplerSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<Object>
,org.reactivestreams.Subscriber<Object>
- Enclosing class:
FlowableSamplePublisher<T>
static final class FlowableSamplePublisher.SamplerSubscriber<T>
extends Object
implements FlowableSubscriber<Object>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final FlowableSamplePublisher.SamplePublisherSubscriber
<T> -
Constructor Summary
ConstructorsConstructorDescription -
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
-
parent
-
-
Constructor Details
-
SamplerSubscriber
SamplerSubscriber(FlowableSamplePublisher.SamplePublisherSubscriber<T> parent)
-
-
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>
-