Package org.apache.pekko.persistence.query.journal.leveldb

Interface Buffer<T>

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)