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

Merge pull request #17243 from akka/wip-stream-supress-deadletters-patriknw

Browse source 
=str Use some more DeadLetterSuppression
This commit is contained in:
Patrik Nordwall 2015-04-22 21:35:19 +02:00
commit 45da4513af
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala
View file

@ -314,10 +314,10 @@ private[akka] object MultiStreamInputProcessor {
}
}
case class SubstreamOnComplete(key: SubstreamKey)
case class SubstreamOnNext(key: SubstreamKey, element: Any)
case class SubstreamOnError(key: SubstreamKey, e: Throwable)
case class SubstreamStreamOnSubscribe(key: SubstreamKey, subscription: Subscription)
case class SubstreamOnComplete(key: SubstreamKey) extends DeadLetterSuppression
case class SubstreamOnNext(key: SubstreamKey, element: Any) extends DeadLetterSuppression
case class SubstreamOnError(key: SubstreamKey, e: Throwable) extends DeadLetterSuppression
case class SubstreamStreamOnSubscribe(key: SubstreamKey, subscription: Subscription) extends DeadLetterSuppression
class SubstreamInput(val key: SubstreamKey, bufferSize: Int, processor: MultiStreamInputProcessorLike, pump: Pump) extends BatchingInputBuffer(bufferSize, pump) {
// Not driven directly