From 4a961786aad1d0dee15346f93caf1cf0495d71c7 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Tue, 21 Apr 2015 11:34:01 +0200 Subject: [PATCH] =str Use some more DeadLetterSuppression --- .../scala/akka/stream/impl/StreamOfStreamProcessors.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala b/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala index b35065503d..b283591539 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala @@ -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