Class FlowableWithLatestFrom.FlowableWithLatestSubscriber
java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableWithLatestFrom.FlowableWithLatestSubscriber
- All Implemented Interfaces:
FlowableSubscriber<U>
,org.reactivestreams.Subscriber<U>
- Enclosing class:
FlowableWithLatestFrom<T,
U, R>
final class FlowableWithLatestFrom.FlowableWithLatestSubscriber
extends Object
implements FlowableSubscriber<U>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final FlowableWithLatestFrom.WithLatestFromSubscriber
<T, U, R> -
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
-
wlf
-
-
Constructor Details
-
FlowableWithLatestSubscriber
FlowableWithLatestSubscriber(FlowableWithLatestFrom.WithLatestFromSubscriber<T, U, R> wlf)
-
-
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<U>
- Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<U>
-
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<U>
-
onError
- Specified by:
onError
in interfaceorg.reactivestreams.Subscriber<U>
-
onComplete
public void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<U>
-