def consume(self, resp):
        with resp.body_stream() as body:
            buf = []
            while True:
                data = body.read()
                if not data:
                    break
                buf.append(data)
            change = "".join(buf)
            try:
                change = json.loads(change)
            except __HOLE__:
                pass
            self.process_change(change)
            self.stop_event.send(True)
dataset/ETHPy150Open benoitc/couchdbkit/couchdbkit/consumer/ceventlet.py/LongPollChangeConsumer.consume