public interface Buffer<T>
INTERNAL API
  • Method Details

    • buffer

      void buffer(T element)
    • buffer

      void buffer(scala.collection.immutable.Set<T> all)
    • bufferEmpty

      boolean bufferEmpty()
    • bufferSize

      int bufferSize()
    • deliverBuf

      void deliverBuf(Outlet<T> out)
    • doPush

      void doPush(Outlet<T> out, T elem)