subscription_handler.py 文件源码

def on_message(self, message):
        data = json_decode(message)
        subid = data.get('id')
        if data.get('type') == 'subscription_start':
            self.on_subscribe(subid, data)
        elif data.get('type') == 'subscription_end':
            self.on_unsubscribe(subid, data)
        else:
            raise ValueError('Invalid type: {0}'.format(data.get('type')))