EventStore.JVM
EventStore.JVM copied to clipboard
Cannot increase buffer size for persistent actor connection
Hi,
The method which defines this buffer is defined on AbstractPersistentSubscriptionActor
which is package private as the only one actor which implement this interface.
private[eventstore] trait AbstractPersistentSubscriptionActor[T] extends Actor with ActorLogging {
//....
def subscribeToPersistentStream(): Unit = toConnection(PS.Connect(EventStream.Id(streamId.streamId), groupName, BUFFER_SIZE))
}
Can we make it somehow configurable?