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

=str #17167 drop new overflow strategy

Browse source
This commit is contained in:
Martynas Mickevičius 2015-06-01 18:08:13 +03:00
parent 67f8e1b79d
commit e863a9c703
8 changed files with 64 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala
View file

@ -249,6 +249,10 @@ private[akka] final case class Buffer[T](size: Int, overflowStrategy: OverflowSt
buffer.enqueue(elem)
ctx.pull()
}
case DropNew ⇒ { (ctx, elem) ⇒
if (!buffer.isFull) buffer.enqueue(elem)
ctx.pull()
}
case Backpressure ⇒ { (ctx, elem) ⇒
buffer.enqueue(elem)
if (buffer.isFull) ctx.holdUpstream()
@ -608,4 +612,4 @@ private[akka] object Log {
private final val DefaultLoggerName = "akka.stream.Log"
private final val OffInt = LogLevels.Off.asInt
private final val DefaultLogLevels = LogLevels(onElement = Logging.DebugLevel, onFinish = Logging.DebugLevel, onFailure = Logging.ErrorLevel)
}
}