Interface BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B>

Type Parameters:
T - items emitted from the Publisher which are to be buffered using this BufferStrategy.
BC - An intermediate mutable object that holds the items into a buffer before it is emitted.
B - The buffer of items.

public interface BufferStrategy<T,BC extends BufferStrategy.Accumulator<T,B>,B>
A strategy for buffering items emitted from a Publisher.

A buffer strategy represents asynchronous buffer boundaries over which items from a Publisher are buffered. Each item emitted from the boundary Publisher represents the end of the last boundary and start of the next boundary. The first item emitted from this Publisher is treated as the start of the first boundary and Publisher.buffer(BufferStrategy) may decide to defer requesting items from the Publisher on which that operator is applied.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    static interface 
    An intermediate mutable object that holds items till it is finished.
  • Method Summary

    Modifier and Type
    Returns a Publisher representing asynchronous buffer boundaries.
    A rough estimate of the number of items in a buffer.