/** * Type guard to check if a value is an AsyncGenerator * @param value - The value to check * @returns true if the value is an AsyncGenerator */ export declare function isAsyncGenerator(value: any): value is AsyncGenerator; /** * Safely iterate through an AsyncGenerator with error handling * @param generator - The AsyncGenerator to iterate * @param onChunk - Callback for each chunk * @param onError - Optional error handler * @returns Promise that resolves when iteration is complete */ export declare function iterateAsyncGenerator(generator: AsyncGenerator, onChunk: (chunk: T) => Promise | void, onError?: (error: unknown) => void): Promise; /** * Collect all chunks from an AsyncGenerator into an array * Useful for testing or converting streaming responses to non-streaming * @param generator - The AsyncGenerator to collect from * @returns Promise resolving to array of all chunks */ export declare function collectStreamChunks(generator: AsyncGenerator): Promise; //# sourceMappingURL=streaming.utils.d.ts.map