Skip to content
This repository was archived by the owner on Mar 17, 2026. It is now read-only.

Commit 8bf0b89

Browse files
committed
style: remove extraneous underscores
1 parent a2a5338 commit 8bf0b89

1 file changed

Lines changed: 7 additions & 10 deletions

File tree

src/message-stream.ts

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff 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.

0 commit comments

Comments
 (0)