From c6ab269b994cc385a8c4a886b227f4f2e1e1ebee Mon Sep 17 00:00:00 2001 From: Johannes Rudolph Date: Thu, 9 Mar 2017 16:08:12 +0100 Subject: [PATCH] =str optimize Keep.none --- .../src/main/scala/akka/stream/impl/TraversalBuilder.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala b/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala index a4a78adc93..bb69f09e49 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala @@ -519,6 +519,8 @@ object LinearTraversalBuilder { Pop.concat(t) else if (matCompose eq Keep.right) t.concat(Pop) + else if (matCompose eq Keep.none) + t.concat(Pop).concat(Pop).concat(PushNotUsed) else t.concat(ComposeReversed(matCompose)) }