akka-stream-contrib
akka-stream-contrib copied to clipboard
An initially-opened Pulse Stage should emit the first available element
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)