Method _wait_until

test/test_change_stream.py:174–175

()

            # up once an event that sorts after it shows up on the other
            # shard. So, we wait on try_next to eventually return changes.
            def _wait_until():
                return stream.try_next() is not None

            wait_until(_wait_until, "get change from try_next")