streaming.py 文件源码

def handle_line(self, raw_line):
        try:
            line = raw_line.decode('utf-8')
        except UnicodeDecodeError as err:
            six.raise_from(
                MastodonMalformedEventError("Malformed UTF-8"),
                err
            )

        if line.startswith(':'):
            self.handle_heartbeat()
        elif line == '':
            # end of event
            self._dispatch(self.event)
            self.event = {}
        else:
            key, value = line.split(': ', 1)
            # According to the MDN spec, repeating the 'data' key
            # represents a newline(!)
            if key in self.event:
                self.event[key] += '\n' + value
            else:
                self.event[key] = value