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?