| 123456789101112131415161718192021222324252627282930313233343536373839404142434445 |
- import { Result, Task, McpError } from '../types.js';
- /**
- * Base message type
- */
- export interface BaseResponseMessage {
- type: string;
- }
- /**
- * Task status update message
- */
- export interface TaskStatusMessage extends BaseResponseMessage {
- type: 'taskStatus';
- task: Task;
- }
- /**
- * Task created message (first message for task-augmented requests)
- */
- export interface TaskCreatedMessage extends BaseResponseMessage {
- type: 'taskCreated';
- task: Task;
- }
- /**
- * Final result message (terminal)
- */
- export interface ResultMessage<T extends Result> extends BaseResponseMessage {
- type: 'result';
- result: T;
- }
- /**
- * Error message (terminal)
- */
- export interface ErrorMessage extends BaseResponseMessage {
- type: 'error';
- error: McpError;
- }
- /**
- * Union type representing all possible messages that can be yielded during request processing.
- * Note: Progress notifications are handled through the existing onprogress callback mechanism.
- * Side-channeled messages (server requests/notifications) are handled through registered handlers.
- */
- export type ResponseMessage<T extends Result> = TaskStatusMessage | TaskCreatedMessage | ResultMessage<T> | ErrorMessage;
- export type AsyncGeneratorValue<T> = T extends AsyncGenerator<infer U> ? U : never;
- export declare function toArrayAsync<T extends AsyncGenerator<unknown>>(it: T): Promise<AsyncGeneratorValue<T>[]>;
- export declare function takeResult<T extends Result, U extends AsyncGenerator<ResponseMessage<T>>>(it: U): Promise<T>;
- //# sourceMappingURL=responseMessage.d.ts.map
|