diff --git a/etcd3gw/watch.py b/etcd3gw/watch.py
index d639de1..2a2cfd7 100644
--- a/etcd3gw/watch.py
+++ b/etcd3gw/watch.py
@@ -11,6 +11,8 @@
 #    under the License.
 
 import json
+import six
+import socket
 
 from etcd3gw.utils import _decode
 from etcd3gw.utils import _encode
@@ -63,7 +65,14 @@ def __init__(self, client, key, callback, **kwargs):
 
     def stop(self):
         try:
-            self._response.raw._fp.close()
+            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()