Class FlowableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R>
java.lang.Object
io.reactivex.rxjava3.internal.jdk8.FlowableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Disposable
,org.reactivestreams.Subscriber<T>
- Enclosing class:
FlowableCollectWithCollectorSingle<T,
A, R>
static final class FlowableCollectWithCollectorSingle.CollectorSingleObserver<T,A,R>
extends Object
implements FlowableSubscriber<T>, Disposable
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final BiConsumer
<A, T> (package private) A
(package private) boolean
(package private) final SingleObserver
<? super R> (package private) org.reactivestreams.Subscription
-
Constructor Summary
ConstructorsConstructorDescriptionCollectorSingleObserver
(SingleObserver<? super R> downstream, A container, BiConsumer<A, T> accumulator, Function<A, R> finisher) -
Method Summary
Modifier and TypeMethodDescriptionvoid
dispose()
Dispose the resource, the operation should be idempotent.boolean
Returns true if this resource has been disposed.void
void
void
void
onSubscribe
(@NonNull 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
-
accumulator
-
finisher
-
upstream
org.reactivestreams.Subscription upstream -
done
boolean done -
container
A container
-
-
Constructor Details
-
CollectorSingleObserver
CollectorSingleObserver(SingleObserver<? super R> downstream, A container, BiConsumer<A, T> accumulator, Function<A, R> finisher)
-
-
Method Details
-
onSubscribe
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>
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-