Class FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U extends java.util.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 java.util.Collection<? super T>,B>
static final class FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U extends java.util.Collection<? super T>,B> extends DisposableSubscriber<B>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B>
parent
-
Constructor Summary
Constructors Constructor Description BufferBoundarySubscriber(FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B> parent)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
onComplete()
void
onError(java.lang.Throwable t)
void
onNext(B t)
-
Methods inherited from class io.reactivex.rxjava3.subscribers.DisposableSubscriber
cancel, dispose, isDisposed, onStart, onSubscribe, request
-
-
-
-
Field Detail
-
parent
final FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U extends java.util.Collection<? super T>,B> parent
-
-
Constructor Detail
-
BufferBoundarySubscriber
BufferBoundarySubscriber(FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B> parent)
-
-
Method Detail
-
onNext
public void onNext(B t)
-
onError
public void onError(java.lang.Throwable t)
-
onComplete
public void onComplete()
-
-