OperatorBufferWithSingleObservable

java.lang.Object
- rx.internal.operators.OperatorBufferWithSingleObservable<T,TClosing>

Type Parameters:

T - the buffered value type

TClosing - the value type of the Observable signaling the end of each buffer

All Implemented Interfaces:

Func1<Subscriber<? super java.util.List<T>>,Subscriber<? super T>>, Function, Observable.Operator<java.util.List<T>,T>
```
public final class OperatorBufferWithSingleObservable<T,TClosing>
extends java.lang.Object
implements Observable.Operator<java.util.List<T>,T>
```
This operation takes values from the specified Observable source and stores them in a buffer until the Observable constructed using the Func0 argument, produces a value. The buffer is then emitted, and a new buffer is created to replace it. A new Observable will be constructed using the provided Func0 object, which will determine when this new buffer is emitted. When the source Observable completes or produces an error, the current buffer is emitted, and the event is propagated to all subscribed Observers.
Note that this operation only produces non-overlapping chunks. At all times there is exactly one buffer actively storing values.

Nested Class Summary

Nested Classes
Modifier and Type Class Description

(package private) class OperatorBufferWithSingleObservable.BufferingSubscriber

Field Summary

Fields
Modifier and Type Field Description

(package private) Func0<? extends Observable<? extends TClosing>> bufferClosingSelector

(package private) int initialCapacity

Constructor Summary

Constructors
Constructor	Description
`OperatorBufferWithSingleObservable(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector, int initialCapacity)`
`OperatorBufferWithSingleObservable(Observable<? extends TClosing> bufferClosing, int initialCapacity)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

Subscriber<? super T> call(Subscriber<? super java.util.List<T>> child)
- Methods inherited from class java.lang.Object
  clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - bufferClosingSelector
```
final Func0<? extends Observable<? extends TClosing>> bufferClosingSelector
```
  - initialCapacity
```
final int initialCapacity
```
- Constructor Detail
  - OperatorBufferWithSingleObservable
```
public OperatorBufferWithSingleObservable(Func0<? extends Observable<? extends TClosing>> bufferClosingSelector,
                                          int initialCapacity)
```
    Parameters:
    
    bufferClosingSelector - a Func0 object which produces Observables. These Observables determine when a buffer is emitted and replaced by simply producing an object.
    
    initialCapacity - the initial capacity of each buffer
  - OperatorBufferWithSingleObservable
```
public OperatorBufferWithSingleObservable(Observable<? extends TClosing> bufferClosing,
                                          int initialCapacity)
```
    Parameters:
    
    bufferClosing - An Observable to determine when a buffer is emitted and replaced by simply producing an object.
    
    initialCapacity - the initial capacity of each buffer
- Method Detail
  - call
```
public Subscriber<? super T> call(Subscriber<? super java.util.List<T>> child)
```
    Specified by:
    
    call in interface Func1<T,TClosing>