diff --git a/index.js b/index.js
index ceffec1..4c65929 100644
--- a/index.js
+++ b/index.js
@@ -94,8 +94,6 @@ function attachFinishedListener (msg, callback) {
 
   function onFinish (error) {
     eeMsg.cancel()
-    eeSocket.cancel()
-
     finished = true
     callback(error)
   }
@@ -121,7 +119,7 @@ function attachFinishedListener (msg, callback) {
 
   if (msg.socket) {
     // socket already assigned
-    defer(onSocket, msg.socket)
+    onSocket(msg.socket)
     return
   }