

def consume(self):
    try:
        while True:
            result = self.reader.read()
            if (not result):
                break
    except IOError:
        pass

dataset/ETHPy150Open CouchPotato/CouchPotatoServer/libs/tornado/platform/posix.py Waker.consume/original