bet-mcp

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