raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

!str #16983 add outputBurstLimit

Browse source 
This limits the number of elements that the ActorInterpreter will allow
the OneBoundedInterpreter to emit during one message processing.
This commit is contained in:
Roland Kuhn 2015-03-03 21:05:53 +01:00
parent 513882ab22
commit a531058c04
8 changed files with 253 additions and 60 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/ActorFlowMaterializer.scala
View file

@ -171,6 +171,7 @@ object ActorFlowMaterializerSettings {
supervisionDecider = Supervision.stoppingDecider,
subscriptionTimeoutSettings = StreamSubscriptionTimeoutSettings(config),
debugLogging = config.getBoolean("debug-logging"),
outputBurstLimit = config.getInt("output-burst-limit"),
optimizations = Optimizations.none)
/**
@ -205,6 +206,7 @@ final case class ActorFlowMaterializerSettings(
supervisionDecider: Supervision.Decider,
subscriptionTimeoutSettings: StreamSubscriptionTimeoutSettings,
debugLogging: Boolean,
outputBurstLimit: Int,
optimizations: Optimizations) {
require(initialInputBufferSize > 0, "initialInputBufferSize must be > 0")