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
    Closes the buffer, signaling that all items have been emitted.
    int
    Returns the number of items the buffer holds.