Method change_stream

test/test_change_stream.py:71–73

Create a change stream using the default client and return it.

(self, *args, **kwargs)

        raise NotImplementedError

    def change_stream(self, *args, **kwargs):
        """Create a change stream using the default client and return it."""
        return self.change_stream_with_client(self.client, *args, **kwargs)

    def client_with_listener(self, *commands):
        """Return a client with a AllowListEventListener."""