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

=str #19377 improve expectNext() error reporting (if no element signaled)

Browse source
This commit is contained in:
Konrad Malawski 2016-01-07 14:58:50 +01:00
parent 3f9b8f6dd3
commit 86504ec4e2
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala
View file

@ -251,9 +251,13 @@ object TestSubscriber {
/** /**
* Expect and return a stream element. * Expect and return a stream element.
*/ */
def expectNext(): I = probe.receiveOne(probe.remaining) match { def expectNext(): I = {
case OnNext(elem) ⇒ elem.asInstanceOf[I] val t = probe.remaining
case other ⇒ throw new AssertionError("expected OnNext, found " + other) probe.receiveOne(t) match {
case null ⇒ throw new AssertionError(s"Expected OnNext(_), yet no element signaled during $t")
case OnNext(elem) ⇒ elem.asInstanceOf[I]
case other ⇒ throw new AssertionError("expected OnNext, found " + other)
}
} }
/** /**