Class FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U extends Collection<? super T>,B>
java.lang.Object
io.reactivex.rxjava3.subscribers.DisposableSubscriber<B>
io.reactivex.rxjava3.internal.operators.flowable.FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U,B>
- All Implemented Interfaces:
FlowableSubscriber<B>
,Disposable
,org.reactivestreams.Subscriber<B>
- Enclosing class:
FlowableBufferExactBoundary<T,
U extends Collection<? super T>, B>
static final class FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U extends Collection<? super T>,B>
extends DisposableSubscriber<B>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final FlowableBufferExactBoundary.BufferExactBoundarySubscriber
<T, U, B> -
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
Field Details
-
parent
final FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U extends Collection<? super T>, parentB>
-
-
Constructor Details
-
BufferBoundarySubscriber
BufferBoundarySubscriber(FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T, U, B> parent)
-
-
Method Details
-
onNext
-
onError
-
onComplete
public void onComplete()
-