Reduce NodeCallbackStreamManager from 32 -> 16 (#5229)

This commit is contained in:
Chris Stewart 2023-09-06 13:35:03 -05:00 committed by GitHub
parent 433a097449
commit d5c74c086d
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 = 32)(implicit system: ActorSystem)
maxBufferSize: Int = 16)(implicit system: ActorSystem)
extends NodeCallbacks
with StartStopAsync[Unit]
with Logging {