From ac2a890898c39416dbf7dabc09eb25a568effcaa Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Thu, 5 Mar 2015 15:16:37 +0100 Subject: [PATCH] =str correct InterpreterSupervisionSpec --- .../impl/fusing/InterpreterSupervisionSpec.scala | 12 ------------ 1 file changed, 12 deletions(-) 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()