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