Package akka.persistence.query.journal.leveldb

Interface Buffer<T>

  • public interface Buffer<T>
    INTERNAL API

    • Method Detail

      • 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)