class EventBus[E: IEvent]:
    _subscribers: dict[type[E], list[EventHandler[E]]]

    def __init__(self, es: EventStore):
        self._es = es
        self._subscribers = defaultdict(list)

    async def dispatch(self, event: E):
        """
        Notify all subscribers of the event
        """
        for handler in self._subscribers[type(event)]:
            await handler(event)

    @classmethod
    def register(cls, handler: ty.Callable[[E], ty.Awaitable[None]]) -> ty.Callable[
        [E], ty.Awaitable[None]
    ]:
        cls._subscribers[T].append(handler) # pylance would complain this
        return handler