akka-stream-contrib icon indicating copy to clipboard operation
akka-stream-contrib copied to clipboard

An initially-opened Pulse Stage should emit the first available element

Open raboof opened this issue 7 years ago • 0 comments

It's actually not that clear to me why this test has an initialTimeout (and why the source repeats '1', wouldn't it be a more reliable test with Source(1 to 10) or so?

An initially-opened Pulse Stage
[info] - should emit the first available element *** FAILED *** (118 milliseconds)
[info]   The future returned an exception of type: java.util.concurrent.TimeoutException, with message: The first element has not yet passed through in 2 milliseconds.. (PulseSpec.scala:63)
[info]   org.scalatest.exceptions.TestFailedException:
[info]   at org.scalatest.concurrent.Futures$FutureConcept.tryTryAgain$1(Futures.scala:531)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValueImpl(Futures.scala:550)
[info]   at org.scalatest.concurrent.Futures$FutureConcept.futureValueImpl$(Futures.scala:479)
[info]   at org.scalatest.concurrent.ScalaFutures$$anon$1.futureValueImpl(ScalaFutures.scala:275)
[info]   at org.scalatest.concurrent.Futures.whenReady(Futures.scala:676)
[info]   at org.scalatest.concurrent.Futures.whenReady$(Futures.scala:675)
[info]   at akka.stream.contrib.PulseSpecAutoFusingOff.whenReady(PulseSpec.scala:13)
[info]   at akka.stream.contrib.PulseSpec.$anonfun$$init$$7(PulseSpec.scala:63)

raboof avatar Jul 14 '17 14:07 raboof