diff --git a/test/parallel/test-http2-bidirectional-write-deadlock.js b/test/parallel/test-http2-bidirectional-write-deadlock.js index 9dd4b91c5234..306dce021cb0 100644 --- a/test/parallel/test-http2-bidirectional-write-deadlock.js +++ b/test/parallel/test-http2-bidirectional-write-deadlock.js @@ -38,6 +38,7 @@ class StalledClientSocket extends Duplex { super(); this.inner = net.connect(port, common.localhostIPv4); this.inner.on('data', (chunk) => this.push(chunk)); + this.inner.on('end', () => this.push(null)); } _read() { // Incoming data is pushed as it arrives. @@ -54,7 +55,7 @@ class StalledClientSocket extends Duplex { callback(); } _final(callback) { - callback(); + this.inner.end(callback); } _destroy(err, callback) { this.inner.destroy(); @@ -101,7 +102,8 @@ server.listen(0, common.mustCall(() => { stallWrites = false; for (const callback of heldCallbacks) callback(); - client.destroy(); + req.end(); + client.close(); server.close(); })); }));