watch.py 文件源码

def stop(self):
        try:
            if six.PY2:
                self._response.raw._fp.close()
            else:
                s = socket.fromfd(self._response.raw._fp.fileno(),
                                  socket.AF_INET,
                                  socket.SOCK_STREAM)
                s.shutdown(socket.SHUT_RDWR)
                s.close()
        except Exception:
            pass
        self._response.connection.close()
        self._executor.shutdown(wait=False)