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

=str Use some more DeadLetterSuppression

Browse source
This commit is contained in:
Patrik Nordwall 2015-04-21 11:34:01 +02:00
parent 050c0549f3
commit 4a961786aa
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

@ -315,10 +315,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