Class FlowableDoOnLifecycle.SubscriptionLambdaSubscriber<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle.SubscriptionLambdaSubscriber<T>
- All Implemented Interfaces:
FlowableSubscriber<T>, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription
- Enclosing class:
FlowableDoOnLifecycle<T>
static final class FlowableDoOnLifecycle.SubscriptionLambdaSubscriber<T>
extends Object
implements FlowableSubscriber<T>, org.reactivestreams.Subscription
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final org.reactivestreams.Subscriber<? super T> (package private) final Action(package private) final LongConsumer(package private) final Consumer<? super org.reactivestreams.Subscription> (package private) org.reactivestreams.Subscription -
Constructor Summary
ConstructorsConstructorDescriptionSubscriptionLambdaSubscriber(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) -
Method Summary
Modifier and TypeMethodDescriptionvoidcancel()voidvoidvoidvoidonSubscribe(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).voidrequest(long n)
-
Field Details
-
downstream
-
onSubscribe
-
onRequest
-
onCancel
-
upstream
org.reactivestreams.Subscription upstream
-
-
Constructor Details
-
SubscriptionLambdaSubscriber
SubscriptionLambdaSubscriber(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel)
-
-
Method Details
-
onSubscribe
public void onSubscribe(org.reactivestreams.Subscription s) Description copied from interface:FlowableSubscriberImplementors 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:
onSubscribein interfaceFlowableSubscriber<T>- Specified by:
onSubscribein interfaceorg.reactivestreams.Subscriber<T>
-
onNext
-
onError
-
onComplete
public void onComplete()- Specified by:
onCompletein interfaceorg.reactivestreams.Subscriber<T>
-
request
public void request(long n) - Specified by:
requestin interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancelin interfaceorg.reactivestreams.Subscription
-