The next part is implementing the poll_next methods on the ChangeStream's Stream implementation without getMore/resumability.

Also, we need to write tests to make sure the stream functionality works properly.