This repository was archived by the owner on Mar 17, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -154,27 +154,24 @@ export class MessageStream extends PassThrough {
154154 /**
155155 * Destroys the stream and any underlying streams.
156156 *
157- * @param {error? } _error An error to emit, if any.
157+ * @param {error? } error An error to emit, if any.
158158 * @private
159159 */
160- destroy ( _error ?: Error | null ) : void {
160+ destroy ( error ?: Error | null ) : void {
161161 // We can't assume Node has taken care of this in <14.
162162 if ( this . destroyed ) {
163163 return ;
164164 }
165- super . destroy ( _error ? _error : undefined ) ;
165+ super . destroy ( error ? error : undefined ) ;
166166 }
167167 /**
168168 * Destroys the stream and any underlying streams.
169169 *
170- * @param {error? } _error An error to emit, if any.
171- * @param {Function } _callback Callback for completion of any destruction.
170+ * @param {error? } error An error to emit, if any.
171+ * @param {Function } callback Callback for completion of any destruction.
172172 * @private
173173 */
174- _destroy (
175- _error : Error | null ,
176- _callback : ( error : Error | null ) => void
177- ) : void {
174+ _destroy ( error : Error | null , callback : ( error : Error | null ) => void ) : void {
178175 this . destroyed = true ;
179176 clearInterval ( this . _keepAliveHandle ) ;
180177
@@ -183,7 +180,7 @@ export class MessageStream extends PassThrough {
183180 stream . cancel ( ) ;
184181 }
185182
186- _callback ( _error ) ;
183+ callback ( error ) ;
187184 }
188185 /**
189186 * Adds a StreamingPull stream to the combined stream.
You can’t perform that action at this time.
0 commit comments