diff --git a/lib/internal/streams/destroy.js b/lib/internal/streams/destroy.js
index 7d3657443e6ab5..efa09e05eafef0 100644
--- a/lib/internal/streams/destroy.js
+++ b/lib/internal/streams/destroy.js
@@ -292,10 +292,14 @@ function constructNT(stream) {
         then.call(
           result,
           function() {
-            process.nextTick(onConstruct, null);
+            if (!called) {
+              process.nextTick(onConstruct, null);
+            }
           },
           function(err) {
-            process.nextTick(onConstruct, err);
+            if (!called) {
+              process.nextTick(onConstruct, err);
+            }
           });
       }
     }
diff --git a/lib/internal/streams/writable.js b/lib/internal/streams/writable.js
index 727e7ede71f8aa..38bfea52a15bfd 100644
--- a/lib/internal/streams/writable.js
+++ b/lib/internal/streams/writable.js
@@ -699,10 +699,14 @@ function callFinal(stream, state) {
         then.call(
           result,
           function() {
-            process.nextTick(onFinish, null);
+            if (!called) {
+              process.nextTick(onFinish, null);
+            }
           },
           function(err) {
-            process.nextTick(onFinish, err);
+            if (!called) {
+              process.nextTick(onFinish, err);
+            }
           });
       }
     }