FM / lib

/opt/canhelp/node_modules/@anthropic-ai/sdk/lib/

/opt/canhelp/node_modules/@anthropic-ai/sdk/lib

Name	Size	Mode	Actions
tools/	-	0755	rm
beta-parser.d.mts	2046	0644	edit dl rm
beta-parser.d.mts.map	1700	0644	edit dl rm
beta-parser.d.ts	2043	0644	edit dl rm
beta-parser.d.ts.map	1699	0644	edit dl rm
beta-parser.js	2959	0644	edit dl rm
beta-parser.js.map	2299	0644	edit dl rm
beta-parser.mjs	2796	0644	edit dl rm
beta-parser.mjs.map	2287	0644	edit dl rm
BetaMessageStream.d.mts	6864	0644	edit dl rm
BetaMessageStream.d.mts.map	3767	0644	edit dl rm
BetaMessageStream.d.ts	6858	0644	edit dl rm
BetaMessageStream.d.ts.map	3766	0644	edit dl rm
BetaMessageStream.js	31897	0644	edit dl rm
BetaMessageStream.js.map	19057	0644	edit dl rm
BetaMessageStream.mjs	31099	0644	edit dl rm
BetaMessageStream.mjs.map	19064	0644	edit dl rm
MessageStream.d.mts	6728	0644	edit dl rm
MessageStream.d.mts.map	3844	0644	edit dl rm
MessageStream.d.ts	6722	0644	edit dl rm
MessageStream.d.ts.map	3843	0644	edit dl rm
MessageStream.js	29827	0644	edit dl rm
MessageStream.js.map	18126	0644	edit dl rm
MessageStream.mjs	29068	0644	edit dl rm
MessageStream.mjs.map	18134	0644	edit dl rm
parser.d.mts	1591	0644	edit dl rm
parser.d.mts.map	1512	0644	edit dl rm
parser.d.ts	1588	0644	edit dl rm
parser.d.ts.map	1511	0644	edit dl rm
parser.js	2159	0644	edit dl rm
parser.js.map	1923	0644	edit dl rm
parser.mjs	2012	0644	edit dl rm
parser.mjs.map	1911	0644	edit dl rm
stainless-helper-header.d.mts	1364	0644	edit dl rm
stainless-helper-header.d.mts.map	756	0644	edit dl rm
stainless-helper-header.d.ts	1362	0644	edit dl rm
stainless-helper-header.d.ts.map	755	0644	edit dl rm
stainless-helper-header.js	2522	0644	edit dl rm
stainless-helper-header.js.map	1633	0644	edit dl rm
stainless-helper-header.mjs	2151	0644	edit dl rm
stainless-helper-header.mjs.map	1611	0644	edit dl rm
transform-json-schema.d.mts	179	0644	edit dl rm
transform-json-schema.d.mts.map	257	0644	edit dl rm
transform-json-schema.d.ts	178	0644	edit dl rm
transform-json-schema.d.ts.map	256	0644	edit dl rm
transform-json-schema.js	4153	0644	edit dl rm
transform-json-schema.js.map	4166	0644	edit dl rm
transform-json-schema.mjs	3847	0644	edit dl rm
transform-json-schema.mjs.map	4093	0644	edit dl rm

Edit: /opt/canhelp/node_modules/@anthropic-ai/sdk/lib/BetaMessageStream.d.ts (6858B)

import type { Logger } from "../client.js";
import { AnthropicError, APIUserAbortError } from "../error.js";
import { type RequestOptions } from "../internal/request-options.js";
import { type BetaContentBlock, type BetaMCPToolUseBlock, type BetaMessage, type BetaMessageParam, Messages as BetaMessages, type BetaRawMessageStreamEvent as BetaMessageStreamEvent, type BetaServerToolUseBlock, type BetaTextCitation, type BetaToolUseBlock, type MessageCreateParams, type MessageCreateParamsBase } from "../resources/beta/messages/messages.js";
import { type ParsedBetaMessage } from "./beta-parser.js";
export interface MessageStreamEvents {
    connect: () => void;
    streamEvent: (event: BetaMessageStreamEvent, snapshot: BetaMessage) => void;
    text: (textDelta: string, textSnapshot: string) => void;
    citation: (citation: BetaTextCitation, citationsSnapshot: BetaTextCitation[]) => void;
    inputJson: (partialJson: string, jsonSnapshot: unknown) => void;
    thinking: (thinkingDelta: string, thinkingSnapshot: string) => void;
    signature: (signature: string) => void;
    compaction: (compactedContent: string) => void;
    message: (message: BetaMessage) => void;
    contentBlock: (content: BetaContentBlock) => void;
    finalMessage: (message: BetaMessage) => void;
    error: (error: AnthropicError) => void;
    abort: (error: APIUserAbortError) => void;
    end: () => void;
}
export type TracksToolInput = BetaToolUseBlock | BetaServerToolUseBlock | BetaMCPToolUseBlock;
export declare class BetaMessageStream<ParsedT = null> implements AsyncIterable<BetaMessageStreamEvent> {
    #private;
    messages: BetaMessageParam[];
    receivedMessages: ParsedBetaMessage<ParsedT>[];
    controller: AbortController;
    constructor(params: MessageCreateParamsBase | null, opts?: {
        logger?: Logger | undefined;
    });
    get response(): Response | null | undefined;
    get request_id(): string | null | undefined;
    /**
     * Returns the `MessageStream` data, the raw `Response` instance and the ID of the request,
     * returned vie the `request-id` header which is useful for debugging requests and resporting
     * issues to Anthropic.
     *
     * This is the same as the `APIPromise.withResponse()` method.
     *
     * This method will raise an error if you created the stream using `MessageStream.fromReadableStream`
     * as no `Response` is available.
     */
    withResponse(): Promise<{
        data: BetaMessageStream<ParsedT>;
        response: Response;
        request_id: string | null | undefined;
    }>;
    /**
     * Intended for use on the frontend, consuming a stream produced with
     * `.toReadableStream()` on the backend.
     *
     * Note that messages sent to the model do not appear in `.on('message')`
     * in this context.
     */
    static fromReadableStream(stream: ReadableStream): BetaMessageStream;
    static createMessage<ParsedT>(messages: BetaMessages, params: MessageCreateParamsBase, options?: RequestOptions, { logger }?: {
        logger?: Logger | undefined;
    }): BetaMessageStream<ParsedT>;
    protected _run(executor: () => Promise<any>): void;
    protected _addMessageParam(message: BetaMessageParam): void;
    protected _addMessage(message: ParsedBetaMessage<ParsedT>, emit?: boolean): void;
    protected _createMessage(messages: BetaMessages, params: MessageCreateParams, options?: RequestOptions): Promise<void>;
    protected _connected(response: Response | null): void;
    get ended(): boolean;
    get errored(): boolean;
    get aborted(): boolean;
    abort(): void;
    /**
     * Adds the listener function to the end of the listeners array for the event.
     * No checks are made to see if the listener has already been added. Multiple calls passing
     * the same combination of event and listener will result in the listener being added, and
     * called, multiple times.
     * @returns this MessageStream, so that calls can be chained
     */
    on<Event extends keyof MessageStreamEvents>(event: Event, listener: MessageStreamEvents[Event]): this;
    /**
     * Removes the specified listener from the listener array for the event.
     * off() will remove, at most, one instance of a listener from the listener array. If any single
     * listener has been added multiple times to the listener array for the specified event, then
     * off() must be called multiple times to remove each instance.
     * @returns this MessageStream, so that calls can be chained
     */
    off<Event extends keyof MessageStreamEvents>(event: Event, listener: MessageStreamEvents[Event]): this;
    /**
     * Adds a one-time listener function for the event. The next time the event is triggered,
     * this listener is removed and then invoked.
     * @returns this MessageStream, so that calls can be chained
     */
    once<Event extends keyof MessageStreamEvents>(event: Event, listener: MessageStreamEvents[Event]): this;
    /**
     * This is similar to `.once()`, but returns a Promise that resolves the next time
     * the event is triggered, instead of calling a listener callback.
     * @returns a Promise that resolves the next time given event is triggered,
     * or rejects if an error is emitted.  (If you request the 'error' event,
     * returns a promise that resolves with the error).
     *
     * Example:
     *
     *   const message = await stream.emitted('message') // rejects if the stream errors
     */
    emitted<Event extends keyof MessageStreamEvents>(event: Event): Promise<Parameters<MessageStreamEvents[Event]> extends [infer Param] ? Param : Parameters<MessageStreamEvents[Event]> extends [] ? void : Parameters<MessageStreamEvents[Event]>>;
    done(): Promise<void>;
    get currentMessage(): BetaMessage | undefined;
    /**
     * @returns a promise that resolves with the the final assistant Message response,
     * or rejects if an error occurred or the stream ended prematurely without producing a Message.
     * If structured outputs were used, this will be a ParsedMessage with a `parsed` field.
     */
    finalMessage(): Promise<ParsedBetaMessage<ParsedT>>;
    /**
     * @returns a promise that resolves with the the final assistant Message's text response, concatenated
     * together if there are more than one text blocks.
     * Rejects if an error occurred or the stream ended prematurely without producing a Message.
     */
    finalText(): Promise<string>;
    protected _emit<Event extends keyof MessageStreamEvents>(event: Event, ...args: Parameters<MessageStreamEvents[Event]>): void;
    protected _emitFinal(): void;
    protected _fromReadableStream(readableStream: ReadableStream, options?: RequestOptions): Promise<void>;
    [Symbol.asyncIterator](): AsyncIterator<BetaMessageStreamEvent>;
    toReadableStream(): ReadableStream;
}
//# sourceMappingURL=BetaMessageStream.d.ts.map

cmd: