async def __aenter__(self) -> LocalAsyncEventBroker:
    self._exit_stack = AsyncExitStack()
    self._task_group = create_task_group()
    (await self._exit_stack.enter_async_context(self._task_group))
    return self
async def __aenter__(self) -> LocalAsyncEventBroker:
    self._exit_stack = AsyncExitStack()
    self._task_group = create_task_group()
    (await self._exit_stack.enter_async_context(self._task_group))
    return self