akka.persistence.query.journal.leveldb

Interface DeliveryBuffer<T>

All Known Implementing Classes:

AbstractEventsByPersistenceIdPublisher, AbstractEventsByTagPublisher, AllPersistenceIdsPublisher, CurrentEventsByPersistenceIdPublisher, CurrentEventsByTagPublisher, LiveEventsByPersistenceIdPublisher, LiveEventsByTagPublisher

public interface DeliveryBuffer<T>

INTERNAL API

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Vector<T>	buf()
void	deliverBuf()

Method Detail

buf

scala.collection.immutable.Vector<T> buf()

deliverBuf

void deliverBuf()