diff --git a/src/client/index.ts b/src/client/index.ts index 2c08bcc09..1ad516166 100644 --- a/src/client/index.ts +++ b/src/client/index.ts @@ -278,8 +278,8 @@ export class Client< } } - async ping() { - return this.request({ method: "ping" }, EmptyResultSchema); + async ping(options?: RequestOptions) { + return this.request({ method: "ping" }, EmptyResultSchema, options); } async complete(params: CompleteRequest["params"], options?: RequestOptions) { @@ -290,10 +290,11 @@ export class Client< ); } - async setLoggingLevel(level: LoggingLevel) { + async setLoggingLevel(level: LoggingLevel, options?: RequestOptions) { return this.request( { method: "logging/setLevel", params: { level } }, EmptyResultSchema, + options, ); } @@ -352,17 +353,25 @@ export class Client< ); } - async subscribeResource(params: SubscribeRequest["params"]) { + async subscribeResource( + params: SubscribeRequest["params"], + options?: RequestOptions, + ) { return this.request( { method: "resources/subscribe", params }, EmptyResultSchema, + options, ); } - async unsubscribeResource(params: UnsubscribeRequest["params"]) { + async unsubscribeResource( + params: UnsubscribeRequest["params"], + options?: RequestOptions, + ) { return this.request( { method: "resources/unsubscribe", params }, EmptyResultSchema, + options, ); } diff --git a/src/utils.ts b/src/utils.ts index 11672ecd2..3ca6af286 100644 --- a/src/utils.ts +++ b/src/utils.ts @@ -4,7 +4,7 @@ export function abortAfterTimeout(timeoutMs: number): AbortSignal { const controller = new AbortController(); setTimeout(() => { - controller.abort(); + controller.abort("Timeout exceeded"); }, timeoutMs); return controller.signal;