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
Fields Modifier and Type Field Description (package private) boolean
done
(package private) FlowableWindowBoundary.WindowBoundaryMainSubscriber<T,B>
parent
-
Constructor Summary
Constructors Constructor Description WindowBoundaryInnerSubscriber(FlowableWindowBoundary.WindowBoundaryMainSubscriber<T,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 FlowableWindowBoundary.WindowBoundaryMainSubscriber<T,B> parent
-
done
boolean done
-
-
Constructor Detail
-
WindowBoundaryInnerSubscriber
WindowBoundaryInnerSubscriber(FlowableWindowBoundary.WindowBoundaryMainSubscriber<T,B> parent)
-
-
Method Detail
-
onNext
public void onNext(B t)
-
onError
public void onError(java.lang.Throwable t)
-
onComplete
public void onComplete()
-
-