Interface SourceBuilder.SourceBuffer<T>

Type Parameters:
T - type of the emitted item
All Known Subinterfaces:
SourceBuilder.TimestampedSourceBuffer<T>
Enclosing class:
SourceBuilder<C>

public static interface SourceBuilder.SourceBuffer<T>
The buffer object that the fillBufferFn gets on each call. Used in sources that emit items without a timestamp.

This class isn't thread-safe.

  • Method Summary

    Modifier and Type Method Description
    void add​(T item)
    Adds an item to the buffer.
    void close()
    Closes the buffer, signaling that all items have been emitted.
    int size()
    Returns the number of items the buffer holds.