From 2ae8c53cfc5b63a6f5b65c7634750a9191e2ed7d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Endre=20S=C3=A1ndor=20Varga?= <endre.varga@typesafe.com>
Date: Wed, 8 Mar 2017 14:08:56 +0100
Subject: [PATCH] Fix missing port ID assignment

---
 .../scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala
index 38b96d21c8..4d046faecf 100644
--- a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala
+++ b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala
@@ -194,6 +194,7 @@ trait GraphInterpreterSpecKit extends StreamSpec {
 
     object Upstream extends UpstreamBoundaryStageLogic[Int] {
       override val out = Outlet[Int]("up")
+      out.id = 0
       override def toString = "Upstream"
 
       setHandler(out, new OutHandler {
@@ -207,6 +208,7 @@ trait GraphInterpreterSpecKit extends StreamSpec {
 
     object Downstream extends DownstreamBoundaryStageLogic[Int] {
       override val in = Inlet[Int]("down")
+      in.id = 0
       setHandler(in, new InHandler {
         override def onPush() = {
           // TODO handler needed but should it do anything?