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

FusableProcessorTest failure #22981 (#23994)

Browse source
This commit is contained in:
Johan Andrén 2017-12-05 09:13:15 +01:00 • committed by Arnout Engelen
parent d52be450f3
commit ab05ac78d7
1 changed files with 1 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream-tests-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala
View file

@ -3,9 +3,7 @@
*/ */
package akka.stream.tck package akka.stream.tck
import akka.NotUsed
import akka.stream._ import akka.stream._
import akka.stream.impl.fusing.GraphStages
import akka.stream.scaladsl.Flow import akka.stream.scaladsl.Flow
import org.reactivestreams.Processor import org.reactivestreams.Processor
@ -17,8 +15,7 @@ class FusableProcessorTest extends AkkaIdentityProcessorVerification[Int] {
implicit val materializer = ActorMaterializer(settings)(system) implicit val materializer = ActorMaterializer(settings)(system)
// withAttributes "wraps" the underlying identity and protects it from automatic removal Flow[Int].map(identity).toProcessor.run()
Flow[Int].via(GraphStages.identity.asInstanceOf[Graph[FlowShape[Int, Int], NotUsed]]).named("identity").toProcessor.run()
} }
override def createElement(element: Int): Int = element override def createElement(element: Int): Int = element