From ab05ac78d7343da7d678a9b60ea917662ca4c836 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Tue, 5 Dec 2017 09:13:15 +0100 Subject: [PATCH] FusableProcessorTest failure #22981 (#23994) --- .../test/scala/akka/stream/tck/FusableProcessorTest.scala | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/akka-stream-tests-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala b/akka-stream-tests-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala index 4aba731323..9ea90c3f7f 100644 --- a/akka-stream-tests-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala +++ b/akka-stream-tests-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala @@ -3,9 +3,7 @@ */ package akka.stream.tck -import akka.NotUsed import akka.stream._ -import akka.stream.impl.fusing.GraphStages import akka.stream.scaladsl.Flow import org.reactivestreams.Processor @@ -17,8 +15,7 @@ class FusableProcessorTest extends AkkaIdentityProcessorVerification[Int] { implicit val materializer = ActorMaterializer(settings)(system) - // withAttributes "wraps" the underlying identity and protects it from automatic removal - Flow[Int].via(GraphStages.identity.asInstanceOf[Graph[FlowShape[Int, Int], NotUsed]]).named("identity").toProcessor.run() + Flow[Int].map(identity).toProcessor.run() } override def createElement(element: Int): Int = element