Add all the original files from the deleted 0.2.8 npm package

vendor/sdk/streaming.d.ts

@@ -0,0 +1,36 @@
+                              
+import { ReadableStream, type Response } from "./_shims/index.js";
+export type ServerSentEvent = {
+    event: string | null;
+    data: string;
+    raw: string[];
+};
+export declare class Stream<Item> implements AsyncIterable<Item> {
+    private iterator;
+    controller: AbortController;
+    constructor(iterator: () => AsyncIterator<Item>, controller: AbortController);
+    static fromSSEResponse<Item>(response: Response, controller: AbortController): Stream<Item>;
+    /**
+     * Generates a Stream from a newline-separated ReadableStream
+     * where each item is a JSON value.
+     */
+    static fromReadableStream<Item>(readableStream: ReadableStream, controller: AbortController): Stream<Item>;
+    [Symbol.asyncIterator](): AsyncIterator<Item>;
+    /**
+     * Splits the stream into two streams which can be
+     * independently read from at different speeds.
+     */
+    tee(): [Stream<Item>, Stream<Item>];
+    /**
+     * 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<ServerSentEvent, void, unknown>;
+/** This is an internal helper function that's just used for testing */
+export declare function _decodeChunks(chunks: string[], { flush }?: {
+    flush: boolean;
+}): string[];
+//# sourceMappingURL=streaming.d.ts.map