stream.d.ts 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738
  1. import type { IterableReadableStreamInterface } from "../types/_internal.js";
  2. export type { IterableReadableStreamInterface };
  3. export declare class IterableReadableStream<T> extends ReadableStream<T> implements IterableReadableStreamInterface<T> {
  4. reader: ReadableStreamDefaultReader<T>;
  5. ensureReader(): void;
  6. next(): Promise<IteratorResult<T>>;
  7. return(): Promise<IteratorResult<T>>;
  8. throw(e: any): Promise<IteratorResult<T>>;
  9. [Symbol.asyncIterator](): this;
  10. [Symbol.asyncDispose](): Promise<void>;
  11. static fromReadableStream<T>(stream: ReadableStream<T>): IterableReadableStream<T>;
  12. static fromAsyncGenerator<T>(generator: AsyncGenerator<T>): IterableReadableStream<T>;
  13. }
  14. export declare function atee<T>(iter: AsyncGenerator<T>, length?: number): AsyncGenerator<T>[];
  15. export declare function concat<T extends Array<any> | string | number | Record<string, any> | any>(first: T, second: T): T;
  16. export declare class AsyncGeneratorWithSetup<S = unknown, T = unknown, TReturn = unknown, TNext = unknown> implements AsyncGenerator<T, TReturn, TNext> {
  17. private generator;
  18. setup: Promise<S>;
  19. config?: unknown;
  20. signal?: AbortSignal;
  21. private firstResult;
  22. private firstResultUsed;
  23. constructor(params: {
  24. generator: AsyncGenerator<T>;
  25. startSetup?: () => Promise<S>;
  26. config?: unknown;
  27. signal?: AbortSignal;
  28. });
  29. next(...args: [] | [TNext]): Promise<IteratorResult<T>>;
  30. return(value?: TReturn | PromiseLike<TReturn>): Promise<IteratorResult<T>>;
  31. throw(e: Error): Promise<IteratorResult<T>>;
  32. [Symbol.asyncIterator](): this;
  33. [Symbol.asyncDispose](): Promise<void>;
  34. }
  35. export declare function pipeGeneratorWithSetup<S, A extends unknown[], T, TReturn, TNext, U, UReturn, UNext>(to: (g: AsyncGenerator<T, TReturn, TNext>, s: S, ...args: A) => AsyncGenerator<U, UReturn, UNext>, generator: AsyncGenerator<T, TReturn, TNext>, startSetup: () => Promise<S>, signal: AbortSignal | undefined, ...args: A): Promise<{
  36. output: AsyncGenerator<U, UReturn, UNext>;
  37. setup: Awaited<S>;
  38. }>;