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

#20638: Harden TickSourceSpec (#21095)

Browse source
This commit is contained in:
drewhk 2016-08-03 11:43:55 +02:00 • committed by Konrad Malawski
parent b005c906d9
commit c8026dc714
1 changed files with 4 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

13
akka-stream-tests/src/test/scala/akka/stream/scaladsl/TickSourceSpec.scala
View file

@ -15,12 +15,9 @@ class TickSourceSpec extends StreamSpec {
"A Flow based on tick publisher" must {
"produce ticks" in assertAllStagesStopped {
val c = TestSubscriber.manualProbe[String]()
Source.tick(1.second, 500.millis, "tick").to(Sink.fromSubscriber(c)).run()
Source.tick(1.second, 1.second, "tick").to(Sink.fromSubscriber(c)).run()
val sub = c.expectSubscription()
sub.request(3)
c.expectNoMsg(600.millis)
c.expectNext("tick")
c.expectNoMsg(200.millis)
sub.request(2)
c.expectNext("tick")
c.expectNoMsg(200.millis)
c.expectNext("tick")
@ -84,16 +81,14 @@ class TickSourceSpec extends StreamSpec {
"be possible to cancel" in assertAllStagesStopped {
val c = TestSubscriber.manualProbe[String]()
val tickSource = Source.tick(1.second, 500.millis, "tick")
val tickSource = Source.tick(1.second, 1.second, "tick")
val cancellable = tickSource.to(Sink.fromSubscriber(c)).run()
val sub = c.expectSubscription()
sub.request(3)
sub.request(2)
c.expectNoMsg(600.millis)
c.expectNext("tick")
c.expectNoMsg(200.millis)
c.expectNext("tick")
c.expectNoMsg(200.millis)
c.expectNext("tick")
cancellable.cancel()
awaitCond(cancellable.isCancelled)
sub.request(3)