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