diff --git a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala index c3ef66cbf0..c44e22e10e 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/PhasedFusingActorMaterializer.scala @@ -203,7 +203,7 @@ private final case class SavedIslandData(islandGlobalOffset: Int, lastVisitedOff @InternalApi private[akka] def exitIsland(): Unit = { val parentIsland = islandStateStack.remove(islandStateStack.size() - 1) - val previousSegmentLength = completeSegment() + completeSegment() // We start a new segment currentSegmentGlobalOffset = currentGlobalOffset 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 b1f1849019..ed7ac6ed6e 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/TraversalBuilder.scala @@ -801,7 +801,6 @@ import scala.collection.immutable.Map.Map1 pendingBuilder = OptionVal.None, beforeBuilder = EmptyTraversal) case OptionVal.None ⇒ - copy(outPort = OptionVal.None, traversalSoFar = rewireLastOutTo(traversalSoFar, relativeSlot)) copy( outPort = OptionVal.None, traversalSoFar = rewireLastOutTo(traversalSoFar, relativeSlot))