Method test_next_blocks

test/test_change_stream.py:334–338

Test that next blocks until a change is readable

(self)

    @no_type_check
    @client_context.require_sync
    def test_next_blocks(self):
        """Test that next blocks until a change is readable"""
        # Use a short wait time to speed up the test.
        with self.change_stream(max_await_time_ms=250) as change_stream:
            self._test_next_blocks(change_stream)

    @no_type_check
    @client_context.require_sync