/opt/canhelp/node_modules/@anthropic-ai/sdk/core
Edit: /opt/canhelp/node_modules/@anthropic-ai/sdk/core/streaming.d.mts (1486B)
import { type ReadableStream } from "../internal/shim-types.mjs";
import type { BaseAnthropic } from "../client.mjs";
export type ServerSentEvent = {
event: string | null;
data: string;
raw: string[];
};
export declare class Stream
- implements AsyncIterable
- {
#private;
private iterator;
controller: AbortController;
constructor(iterator: () => AsyncIterator
- , controller: AbortController, client?: BaseAnthropic);
static fromSSEResponse
- (response: Response, controller: AbortController, client?: BaseAnthropic): Stream
- ;
/**
* Generates a Stream from a newline-separated ReadableStream
* where each item is a JSON value.
*/
static fromReadableStream
- (readableStream: ReadableStream, controller: AbortController, client?: BaseAnthropic): Stream
- ;
[Symbol.asyncIterator](): AsyncIterator
- ;
/**
* Splits the stream into two streams which can be
* independently read from at different speeds.
*/
tee(): [Stream
- , Stream
- ];
/**
* Converts this stream to a newline-separated ReadableStream of
* JSON stringified values in the stream
* which can be turned back into a Stream with `Stream.fromReadableStream()`.
*/
toReadableStream(): ReadableStream;
}
export declare function _iterSSEMessages(response: Response, controller: AbortController): AsyncGenerator;
//# sourceMappingURL=streaming.d.mts.map