a pull stream that eagerly reads ahead until it has reached the watermark - View it on GitHub