and this should go in the `._read` function so at least the stream is pull-based.