ObservableWindowBoundary.WindowBoundaryInnerObserver

java.lang.Object
- io.reactivex.rxjava3.observers.DisposableObserver<B>
- - io.reactivex.rxjava3.internal.operators.observable.ObservableWindowBoundary.WindowBoundaryInnerObserver<T,B>

All Implemented Interfaces:: Observer<B>, Disposable

Enclosing class:: ObservableWindowBoundary<T,B>

static final class ObservableWindowBoundary.WindowBoundaryInnerObserver<T,B>
extends DisposableObserver<B>

Field Summary

Fields
Modifier and Type Field Description

(package private) boolean done

(package private) ObservableWindowBoundary.WindowBoundaryMainObserver<T,B> parent

Constructor Summary

Constructors
Constructor Description

WindowBoundaryInnerObserver(ObservableWindowBoundary.WindowBoundaryMainObserver<T,B> parent)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`onComplete()`	Notifies the `Observer` that the `Observable` has finished sending push-based notifications.
`void`	`onError(java.lang.Throwable t)`	Notifies the `Observer` that the `Observable` has experienced an error condition.
`void`	`onNext(B t)`	Provides the `Observer` with a new item to observe.

Methods inherited from class io.reactivex.rxjava3.observers.DisposableObserver
dispose, isDisposed, onStart, onSubscribe

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - parent
```
final ObservableWindowBoundary.WindowBoundaryMainObserver<T,B> parent
```
  - done
```
boolean done
```
- Constructor Detail
  - WindowBoundaryInnerObserver
```
WindowBoundaryInnerObserver(ObservableWindowBoundary.WindowBoundaryMainObserver<T,B> parent)
```
- Method Detail
  - onNext
```
public void onNext(B t)
```
    Description copied from interface: Observer
    
    Provides the Observer with a new item to observe.
    The Observable may call this method 0 or more times.
    The Observable will not call this method again after it calls either Observer.onComplete() or Observer.onError(java.lang.Throwable).
    
    Parameters:
    
    t - the item emitted by the Observable
  - onError
```
public void onError(java.lang.Throwable t)
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has experienced an error condition.
    If the Observable calls this method, it will not thereafter call Observer.onNext(T) or Observer.onComplete().
    
    Parameters:
    
    t - the exception encountered by the Observable
  - onComplete
```
public void onComplete()
```
    Description copied from interface: Observer
    
    Notifies the Observer that the Observable has finished sending push-based notifications.
    The Observable will not call this method if it calls Observer.onError(java.lang.Throwable).