docs: async def _notify(self, message: BaseMessage, responder: Responder):
          """
          Notify all callbacks that a message was received.
          """
          for cb in self._listeners:
              coro = cb(message, responder, self.fsm_creates_task)
  
              if not self.fsm_creates_task:
                  self._register = await coro