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

=str #18037 FlowOps.log exception handler does not follow supervision strategy

Browse source
This commit is contained in:
Alexander Golubev 2015-10-30 22:13:10 -04:00
parent fb3dd99eb3
commit 7a78160c26
4 changed files with 17 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -686,7 +686,9 @@ private[akka] final case class MapAsyncUnordered[In, Out](parallelism: Int, f: I
/**
* INTERNAL API
*/
private[akka] final case class Log[T](name: String, extract: T ⇒ Any, logAdapter: Option[LoggingAdapter]) extends PushStage[T, T] {
private[akka] final case class Log[T](name: String, extract: T ⇒ Any,
logAdapter: Option[LoggingAdapter],
decider: Supervision.Decider) extends PushStage[T, T] {
import Log._
@ -744,6 +746,7 @@ private[akka] final case class Log[T](name: String, extract: T ⇒ Any, logAdapt
private def isEnabled(l: LogLevel): Boolean = l.asInt != OffInt
override def decide(t: Throwable): Supervision.Directive = decider(t)
}
/**