Ensure that a stream is flowing data without mutating it