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

=str correct InterpreterSupervisionSpec

Browse source
This commit is contained in:
Patrik Nordwall 2015-03-05 15:16:37 +01:00
parent 75087a19f2
commit ac2a890898
1 changed files with 0 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala
View file

@ -124,8 +124,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(0) // boom upstream.onNext(0) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(3) upstream.onNext(3)
lastEvents() should be(Set(OnNext(3))) lastEvents() should be(Set(OnNext(3)))
@ -135,8 +133,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(0) // boom upstream.onNext(0) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(4) upstream.onNext(4)
lastEvents() should be(Set(OnNext(4))) lastEvents() should be(Set(OnNext(4)))
} }
@ -156,8 +152,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(-1) // boom upstream.onNext(-1) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(3) upstream.onNext(3)
lastEvents() should be(Set(OnNext(114))) lastEvents() should be(Set(OnNext(114)))
} }
@ -225,8 +219,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(-1) // boom upstream.onNext(-1) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(3) upstream.onNext(3)
lastEvents() should be(Set(OnNext(104))) lastEvents() should be(Set(OnNext(104)))
} }
@ -257,8 +249,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(-1) // boom upstream.onNext(-1) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(3) upstream.onNext(3)
lastEvents() should be(Set(OnNext(104))) lastEvents() should be(Set(OnNext(104)))
} }
@ -322,8 +312,6 @@ class InterpreterSupervisionSpec extends InterpreterSpecKit {
upstream.onNext(0) // boom upstream.onNext(0) // boom
lastEvents() should be(Set(RequestOne)) lastEvents() should be(Set(RequestOne))
downstream.requestOne()
lastEvents() should be(Set(RequestOne))
upstream.onNext(2) upstream.onNext(2)
lastEvents() should be(Set(OnNext(2))) lastEvents() should be(Set(OnNext(2)))
downstream.requestOne() downstream.requestOne()