Commit 7b850a7
http2: destroy() stream, upon errnoException
First steps towards #19060
PR-URL: #19389
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Matteo Collina <matteo.collina@gmail.com>1 parent dac5f67 commit 7b850a7
1 file changed
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1646,7 +1646,7 @@ class Http2Stream extends Duplex { | |||
| 1646 | 1646 | req.async = false; | |
| 1647 | 1647 | const err = createWriteReq(req, handle, data, encoding); | |
| 1648 | 1648 | if (err) | |
| 1649 | - throw errors.errnoException(err, 'write', req.error); | ||
| 1649 | + return this.destroy(errors.errnoException(err, 'write', req.error), cb); | ||
| 1650 | 1650 | trackWriteState(this, req.bytes); | |
| 1651 | 1651 | } | |
| 1652 | 1652 | ||
@@ -1689,7 +1689,7 @@ class Http2Stream extends Duplex { | |||
| 1689 | 1689 | } | |
| 1690 | 1690 | const err = handle.writev(req, chunks); | |
| 1691 | 1691 | if (err) | |
| 1692 | - throw errors.errnoException(err, 'write', req.error); | ||
| 1692 | + return this.destroy(errors.errnoException(err, 'write', req.error), cb); | ||
| 1693 | 1693 | trackWriteState(this, req.bytes); | |
| 1694 | 1694 | } | |
| 1695 | 1695 | ||
0 commit comments