queue does do this waiting internally, but if we did that this stream wouldn't obey backpressure