public final class Buffer
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
Buffer.WithBoundary<T,U>
Buffers the source elements into non-overlapping lists separated
by notification values from the boundary observable and its finish event.
|
static class |
Buffer.WithClosing<T,U>
Buffer parts of the source until the window observable finishes.
|
static class |
Buffer.WithOpenClose<T,U,V>
Projects the incoming values into multiple buffers based on
when a window-open fires an event and a window-close finishes.
|
static class |
Buffer.WithSizeOrTime<T>
Buffer the Ts of the source until the buffer reaches its capacity or the current time unit runs out.
|
static class |
Buffer.WithSizeSkip<T>
Project the source sequence to
potentially overlapping buffers whose
start is determined by skip and lengths
by size.
|
static class |
Buffer.WithTime<T>
Buffers the source observable Ts into a list of Ts periodically and submits them to the returned observable.
|