(stream2, err)
| 1780 | } |
| 1781 | __name(isDestroyed, "isDestroyed"); |
| 1782 | function destroy(stream2, err) { |
| 1783 | if (stream2 == null || !isStream(stream2) || isDestroyed(stream2)) { |
| 1784 | return; |
| 1785 | } |
| 1786 | if (typeof stream2.destroy === "function") { |
| 1787 | if (Object.getPrototypeOf(stream2).constructor === IncomingMessage) { |
| 1788 | stream2.socket = null; |
| 1789 | } |
| 1790 | stream2.destroy(err); |
| 1791 | } else if (err) { |
| 1792 | queueMicrotask(() => { |
| 1793 | stream2.emit("error", err); |
| 1794 | }); |
| 1795 | } |
| 1796 | if (stream2.destroyed !== true) { |
| 1797 | stream2[kDestroyed] = true; |
| 1798 | } |
| 1799 | } |
| 1800 | __name(destroy, "destroy"); |
| 1801 | var KEEPALIVE_TIMEOUT_EXPR = /timeout=(\d+)/; |
| 1802 | function parseKeepAliveTimeout(val) { |
no test coverage detected