refactor: remove public requestStream() overrides from Client and Server

The requestStream() method is task infrastructure - when used without
tasks, it's just a trivial wrapper around request(). Task usage requires
importing from experimental anyway (for TaskStore).

By removing these public overrides, users must access requestStream()
via experimental.tasks.requestStream(), making it clearer that streaming
is part of the experimental tasks feature.

Author: felixweinberger

src/client/index.ts

@@ -1,6 +1,6 @@
 import { mergeCapabilities, Protocol, type ProtocolOptions, type RequestOptions } from '../shared/protocol.js';
 import type { Transport } from '../shared/transport.js';
-import { ResponseMessage, takeResult } from '../shared/responseMessage.js';
+import { takeResult } from '../shared/responseMessage.js';
 
 import {
     type CallToolRequest,
@@ -704,45 +704,4 @@ export class Client<
     async sendRootsListChanged() {
         return this.notification({ method: 'notifications/roots/list_changed' });
     }
-
-    /**
-     * Sends a request and returns an AsyncGenerator that yields response messages.
-     * The generator is guaranteed to end with either a 'result' or 'error' message.
-     *
-     * This method provides streaming access to request processing, allowing you to
-     * observe intermediate task status updates for task-augmented requests.
-     *
-     * @example
-     * ```typescript
-     * const stream = client.requestStream(request, resultSchema, options);
-     * for await (const message of stream) {
-     *   switch (message.type) {
-     *     case 'taskCreated':
-     *       console.log('Task created:', message.task.taskId);
-     *       break;
-     *     case 'taskStatus':
-     *       console.log('Task status:', message.task.status);
-     *       break;
-     *     case 'result':
-     *       console.log('Final result:', message.result);
-     *       break;
-     *     case 'error':
-     *       console.error('Error:', message.error);
-     *       break;
-     *   }
-     * }
-     * ```
-     *
-     * @param request - The request to send
-     * @param resultSchema - Zod schema for validating the result
-     * @param options - Optional request options (timeout, signal, task creation params, etc.)
-     * @returns AsyncGenerator that yields ResponseMessage objects
-     */
-    requestStream<T extends AnyObjectSchema>(
-        request: ClientRequest | RequestT,
-        resultSchema: T,
-        options?: RequestOptions
-    ): AsyncGenerator<ResponseMessage<SchemaOutput<T>>, void, void> {
-        return super.requestStream(request, resultSchema, options);
-    }
 }

src/server/index.ts

@@ -1,5 +1,4 @@
 import { mergeCapabilities, Protocol, type NotificationOptions, type ProtocolOptions, type RequestOptions } from '../shared/protocol.js';
-import { ResponseMessage } from '../shared/responseMessage.js';
 import {
     type ClientCapabilities,
     type CreateMessageRequest,
@@ -42,7 +41,6 @@ import { AjvJsonSchemaValidator } from '../validation/ajv-provider.js';
 import type { JsonSchemaType, jsonSchemaValidator } from '../validation/types.js';
 import {
     AnyObjectSchema,
-    AnySchema,
     getObjectShape,
     isZ4Schema,
     safeParse,
@@ -465,47 +463,6 @@ export class Server<
         return this._capabilities;
     }
 
-    /**
-     * Sends a request and returns an AsyncGenerator that yields response messages.
-     * The generator is guaranteed to end with either a 'result' or 'error' message.
-     *
-     * This method provides streaming access to request processing, allowing you to
-     * observe intermediate task status updates for task-augmented requests.
-     *
-     * @example
-     * ```typescript
-     * const stream = server.requestStream(request, resultSchema, options);
-     * for await (const message of stream) {
-     *   switch (message.type) {
-     *     case 'taskCreated':
-     *       console.log('Task created:', message.task.taskId);
-     *       break;
-     *     case 'taskStatus':
-     *       console.log('Task status:', message.task.status);
-     *       break;
-     *     case 'result':
-     *       console.log('Final result:', message.result);
-     *       break;
-     *     case 'error':
-     *       console.error('Error:', message.error);
-     *       break;
-     *   }
-     * }
-     * ```
-     *
-     * @param request - The request to send
-     * @param resultSchema - Zod schema for validating the result
-     * @param options - Optional request options (timeout, signal, task creation params, etc.)
-     * @returns AsyncGenerator that yields ResponseMessage objects
-     */
-    requestStream<T extends AnySchema>(
-        request: ServerRequest | RequestT,
-        resultSchema: T,
-        options?: RequestOptions
-    ): AsyncGenerator<ResponseMessage<SchemaOutput<T>>, void, void> {
-        return super.requestStream(request, resultSchema, options);
-    }
-
     async ping() {
         return this.request({ method: 'ping' }, EmptyResultSchema);
     }