def get(self):
        rv = self.oq.get(timeout=SOCKET_TIMEOUT+0.1)
        self.worker.join()
        return rv
Get a chunk of data from the ReadWorker's queue.
dataset/ETHPy150Open isislovecruft/obfsproxy/obfsproxy/test/tester.py/ReadWorker.get