debugging

        self._terminate = asyncio.Event()

        self._dltgateway_stream = None

    async def start(self) -> None:

    async def run(self) -> None:

        event_handler = self._event_handler

        if event_handler is None:

            event_handler = lambda e: e

        if self._dltgateway_stream is not None:

            await self._dltgateway_stream.cancel()

# Usage example

async def main():

    gateway_client = DltGatewayClient()

    collector = DltEventsCollector(gateway_client)

    await collector.start()

# Start the event loop

asyncio.run(main())