Reduce NodeCallbackStreamManager to 32 to reduce chance of OOM errors on small heap sizes (#5224)

This commit is contained in:
Chris Stewart 2023-09-05 13:21:23 -05:00 committed by GitHub
parent 0e2fddcc57
commit 489682312d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -20,7 +20,7 @@ import scala.concurrent.{ExecutionContext, Future}
case class NodeCallbackStreamManager(
callbacks: NodeCallbacks,
overflowStrategy: OverflowStrategy = OverflowStrategy.backpressure,
maxBufferSize: Int = 1000)(implicit system: ActorSystem)
maxBufferSize: Int = 32)(implicit system: ActorSystem)
extends NodeCallbacks
with StartStopAsync[Unit]
with Logging {