[09-01 15:20:20.134] [info] - must pass cancellation upstream across remoting before elements has been emitted *** FAILED *** (26 milliseconds)
[09-01 15:20:20.135] [info] java.lang.AssertionError: assertion failed: expected Done, found Failure(org.apache.pekko.stream.RemoteStreamRefActorTerminatedException: Remote target receiver of data Some(Actor[pekko://StreamRefsSpec/system/Materializers/StreamSupervisor-2568/$$m-SourceRef-8#-1525367045]) terminated. Local stream terminating, message loss (on remote side) may have happened.)
[09-01 15:20:20.135] [info] at scala.Predef$.assert(Predef.scala:279)
https://github.com/apache/incubator-pekko/actions/runs/6050882412/job/16421131496?pr=609