I assume does the
implicit requestcoming in, connect to the existing Queue, dequeueing from it, then stream those into the Ok.chunked
Stream.eval_(log.info("got request")) ++ results.dequeue...
dequeuefrom that stale request would maybe pull a message or two before being closed (idk how play closes those streams), and then those that it pulled would not be visible to new requests
.dequeue, try using