def METHOD_NAME(self, msg):
    """Callback for stream.on_recv.
    Unpacks message, and calls handlers with it.
    """
    ident,smsg = self.session.feed_identities(msg)
    msg = self.session.deserialize(smsg)
    # let client inspect messages
    if self._inspect:
        self._inspect(msg)
    self.call_handlers(msg)