

def __init__(self, fd, queue):
    assert isinstance(queue, Queue)
    assert callable(fd.readline)
    threading.Thread.__init__(self)
    self._fd = fd
    self._queue = queue

dataset/ETHPy150Open GoogleCloudPlatform/reliable-task-scheduling-compute-engine-sample/gce/cron_executor.py AsynchronousFileReader.__init__/original