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

Merge pull request #22470 from akka/wip-22463-FlowRecoverWithSpec2-patriknw

Browse source 
fix FlowRecoverWithSpec, #22463
This commit is contained in:
Patrik Nordwall 2017-03-07 14:14:35 +01:00 • committed by GitHub
commit 37610e43bb
1 changed files with 2 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverWithSpec.scala
View file

@ -117,17 +117,13 @@ class FlowRecoverWithSpec extends StreamSpec {
Source(1 to 3).map { a ⇒ if (a == 3) throw new IndexOutOfBoundsException() else a }
.recoverWithRetries(3, {
case t: Throwable ⇒
Source(List(11, 22)).concat(Source.failed(ex))
Source(List(11, 22, 33)).map(m ⇒ if (m == 33) throw ex else m)
}).runWith(TestSink.probe[Int])
.request(2)
.request(100)
.expectNextN(List(1, 2))
.request(2)
.expectNextN(List(11, 22))
.request(2)
.expectNextN(List(11, 22))
.request(2)
.expectNextN(List(11, 22))
.request(1)
.expectError(ex)
}