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

fix up StreamTestKitSpec

Browse source
This commit is contained in:
Roland Kuhn 2016-01-16 17:54:39 +01:00
parent ecc916abfd
commit 960cc5a6e4
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala
View file

@ -22,7 +22,7 @@ class StreamTestKitSpec extends AkkaSpec {
}
"#toStrict with failing source" in {
val msg = intercept[AssertionError] {
val error = intercept[AssertionError] {
Source.fromIterator(() ⇒ new Iterator[Int] {
var i = 0
override def hasNext: Boolean = true
@ -35,10 +35,10 @@ class StreamTestKitSpec extends AkkaSpec {
}
}).runWith(TestSink.probe)
.toStrict(300.millis)
}.getMessage
}
msg should include("Boom!")
msg should include("List(1, 2)")
error.getCause.getMessage should include("Boom!")
error.getMessage should include("List(1, 2)")
}
"#toStrict when subscription was already obtained" in {