We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f726768 commit 1633986Copy full SHA for 1633986
src/lib/BufferedDuplex.ts
@@ -77,6 +77,12 @@ export class BufferedDuplex extends Duplex {
77
this.proxy.end(callback)
78
}
79
80
+ _destroy(err: Error, callback: (error: Error) => void): void {
81
+ this.writeQueue = []
82
+ this.proxy.destroy(err)
83
+ callback(err)
84
+ }
85
+
86
/** Method to call when socket is ready to stop buffering writes */
87
socketReady() {
88
this.emit('connect')
0 commit comments