0xCurtis

class EventListener:
    def __init__(self, uri):
        self.uri = uri
        self.on_message_callbacks = []

    def on_message(self, callback):
        self.on_message_callbacks.append(callback)

    async def _notify_message_received(self, message):
        for callback in self.on_message_callbacks: