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

Fields

Modifier and Type	Field	Description
(package private) final FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B>	parent

Constructor Summary

Constructors

Constructor	Description
BufferBoundarySubscriber(FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B> parent)

Method Summary

Modifier and Type	Method	Description
void	onComplete()
void	onError(Throwable t)
void	onNext(B t)

Methods inherited from class DisposableSubscriber

cancel, dispose, isDisposed, onStart, onSubscribe, request

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

parent

final FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T, U extends Collection<? super T>, B> parent

Constructor Details

BufferBoundarySubscriber

BufferBoundarySubscriber(FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U,B> parent)

Method Details

onNext

public void onNext(B t)

onError

public void onError(Throwable t)

onComplete

public void onComplete()