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)) }