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

=str fix double-dilation in StreamTestKit

Browse source
This commit is contained in:
Konrad Malawski 2015-09-29 10:26:18 +02:00
parent 880d51b89b
commit f416e89edb
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -213,7 +213,7 @@ object TestSubscriber {
* Expect and return [[SubscriberEvent]] (any of: `OnSubscribe`, `OnNext`, `OnError` or `OnComplete`). * Expect and return [[SubscriberEvent]] (any of: `OnSubscribe`, `OnNext`, `OnError` or `OnComplete`).
*/ */
def expectEvent(max: FiniteDuration): SubscriberEvent = def expectEvent(max: FiniteDuration): SubscriberEvent =
probe.expectMsgType[SubscriberEvent](max.dilated) probe.expectMsgType[SubscriberEvent](max)
/** /**
* Fluent DSL * Fluent DSL