Interface SourceBuilder.SourceBuffer<T>

  • Type Parameters:
    T - type of the emitted item
    All Known Subinterfaces:
    Enclosing class:

    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

      All Methods Instance Methods Abstract Methods 
      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.