diff --git a/common.js b/common.js
index ac226ea..d5a0ba3 100644
--- a/common.js
+++ b/common.js
@@ -86,13 +86,17 @@ function streamToSink(stream, end) {
   }
 
   function onRead(err, chunk) {
-    reading = false;
     if (chunk === undefined) {
-      if (end) stream.end();
-      if (err) stream.destroy();
+      if (err) {
+        stream.destroy();
+      }
+      else if (end) {
+        stream.end();
+      }
       callback(err);
     }
     else {
+      reading = false;
       writing = !stream.write(chunk);
       check();
     }