@@ -2721,6 +2721,15 @@ class Http2Stream extends Duplex {
         });
       }
     }
+
+    // A write in flight may never get its native completion callback once the
+    // stream tears down; settle it so the Writable can clean up.
+    if (state.writeCb !== null) {
+      const writeCb = state.writeCb;
+      state.writeCb = null;
+      state.writePending = 0;
+      writeCb(err);
+    }
     callback(err);
   }
   // The Http2Stream can be destroyed if it has closed and if the readable
 
@@ -29,11 +29,21 @@ server.on('session', common.mustCall(function(session) {
     stream.on('error', common.mustCall((err) => {
       assert.strictEqual(err.code, 'ERR_HTTP2_STREAM_ABORTED');
     }));
-    stream.resume();
+
+    // Every write dispatched before close must have its callback invoked.
+    let writes = 0;
+    let writeCallbacks = 0;
     stream.on('data', function() {
-      this.write(Buffer.alloc(1));
+      writes++;
+      this.write(Buffer.alloc(1), () => {
+        writeCallbacks++;
+      });
       process.nextTick(() => client_stream.destroy());
     });
+    stream.on('close', common.mustCall(() => {
+      assert.strictEqual(writeCallbacks, writes);
+    }));
+    stream.resume();
   }));
 }));
Original file line number	Diff line number	Diff line change
`@@ -2721,6 +2721,15 @@ class Http2Stream extends Duplex {`
`2721`	`2721`	`});`
`2722`	`2722`	`}`
`2723`	`2723`	`}`
	`2724`	`+`
	`2725`	`+ // A write in flight may never get its native completion callback once the`
	`2726`	`+ // stream tears down; settle it so the Writable can clean up.`
	`2727`	`+ if (state.writeCb !== null) {`
	`2728`	`+ const writeCb = state.writeCb;`
	`2729`	`+ state.writeCb = null;`
	`2730`	`+ state.writePending = 0;`
	`2731`	`+ writeCb(err);`
	`2732`	`+ }`
`2724`	`2733`	`callback(err);`
`2725`	`2734`	`}`
`2726`	`2735`	`// The Http2Stream can be destroyed if it has closed and if the readable`