def _message_received(self, message):
with self.lock:<EOL><INDENT>self._state.receive_message(message)<EOL>for callable in chain(self._on_message_received, self._on_message):<EOL><INDENT>callable(message)<EOL><DEDENT><DEDENT>
Notify the observers about the received message.