def sockets(self):
        socket = self.client.exec_start(self.exec_id, socket=True, tty=self.interactive)
        stream = io.Stream(socket)
        if self.is_process_tty():
            return stream
        else:
            return io.Demuxer(stream)
async method, put request, response into task queue
dataset/ETHPy150Open d11wtq/dockerpty/dockerpty/pty.py/ExecOperation.sockets--crossover with--dataset/ETHPy150Open jjyr/zerotest/zerotest/record/http_recorder.py/HTTPRecorder.record_http