ddpciao.py 文件源码

def writable(self):
        if not self.shd["loop"]:
            raise asyncore.ExitNow('Connector is quitting!')
        if not self.ciao_queue.empty() and not self.write_pending:
            return True
        return False