diff --git a/etcd3gw/watch.py b/etcd3gw/watch.py
index 2a2cfd7..104265f 100644
--- a/etcd3gw/watch.py
+++ b/etcd3gw/watch.py
@@ -11,7 +11,6 @@
 #    under the License.
 
 import json
-import six
 import socket
 
 from etcd3gw.utils import _decode
@@ -65,14 +64,11 @@ def __init__(self, client, key, callback, **kwargs):
 
     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()
+            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()