diff --git a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala index f4daee0ddd..a7ab9a08cc 100644 --- a/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala +++ b/akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala @@ -124,8 +124,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(0) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(3) lastEvents() should be(Set(OnNext(3))) @@ -135,8 +133,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(0) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(4) lastEvents() should be(Set(OnNext(4))) } @@ -156,8 +152,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(-1) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(3) lastEvents() should be(Set(OnNext(114))) } @@ -225,8 +219,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(-1) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(3) lastEvents() should be(Set(OnNext(104))) } @@ -257,8 +249,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(-1) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(3) lastEvents() should be(Set(OnNext(104))) } @@ -322,8 +312,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit { upstream.onNext(0) // boom lastEvents() should be(Set(RequestOne)) - downstream.requestOne() - lastEvents() should be(Set(RequestOne)) upstream.onNext(2) lastEvents() should be(Set(OnNext(2))) downstream.requestOne()