akka/akka-stream-contrib

FAILED: Pulse Stage should emit the first available element

manonthegithub opened this issue · 7 comments

manonthegithub commented

[info] PulseSpecAutoFusingOff:
[info] Pulse Stage
[info] - should signal demand once every interval (957 milliseconds)
[info] - should keep backpressure if there is no demand from downstream (565 milliseconds)
[info] An initially-opened Pulse Stage
[info] - should emit the first available element *** FAILED *** (174 milliseconds)
[info] A timeout occurred waiting for a future to complete. Queried 7 times, sleeping 15 milliseconds between each query. (PulseSpec.scala:63)
[info] org.scalatest.concurrent.Futures$FutureConcept$$anon$1:
[info] at org.scalatest.concurrent.Futures$FutureConcept.tryTryAgain$1(Futures.scala:538)

manonthegithub commented

Full logs: here

ktoso commented

I assume this was one of the timing issues, closing

raboof commented

Hmm I think this was actually after the timeouts were widened... but not sure, let's just reopen if/when it happens again 👍

ktoso commented

Okey :) sorry if was too eager to close

manonthegithub commented

This issue is still reproducing: logs here,
but the #109 duplicates this

ktoso commented

Thanks, my bad!

manonthegithub commented

I guess either this one or #109 can be closed as duplicate.