/**
 * Streaming Plugin for OpenSpeed
 * Provides support for streaming responses using generators and ReadableStreams
 */
import type { Context } from '../context.js';
export interface StreamOptions {
    headers?: Record<string, string>;
    contentType?: string;
    onError?: (error: Error) => void;
}
export interface SSEOptions extends StreamOptions {
    retry?: number;
    keepAlive?: number;
}
/**
 * Stream plugin - adds streaming helpers to context
 */
export declare function stream(): (ctx: Context, next: () => Promise<any>) => Promise<void>;
/**
 * Create stream from generator function
 */
export declare function createStreamHelper(ctx: Context): (generator: AsyncGenerator<unknown> | Generator<unknown>, options?: StreamOptions) => import("../context.js").ResponseLike;
/**
 * Server-Sent Events (SSE) stream helper
 */
export declare function createSSEHelper(ctx: Context): (generator: AsyncGenerator<unknown> | Generator<unknown>, options?: SSEOptions) => import("../context.js").ResponseLike;
/**
 * JSON streaming helper (NDJSON - newline delimited JSON)
 */
export declare function createJSONStreamHelper(ctx: Context): (generator: AsyncGenerator<unknown> | Generator<unknown>, options?: StreamOptions) => import("../context.js").ResponseLike;
/**
 * Helper to create a generator from an array
 */
export declare function fromArray<T>(array: T[]): AsyncGenerator<T>;
/**
 * Helper to create a generator from a stream
 */
export declare function fromReadableStream<T>(stream: any): AsyncGenerator<T>;
/**
 * Helper to pipe generators
 */
export declare function pipe<T, U>(source: AsyncGenerator<T>, transform: (chunk: T) => U | Promise<U>): AsyncGenerator<U>;
/**
 * Helper to filter generator
 */
export declare function filter<T>(source: AsyncGenerator<T>, predicate: (chunk: T) => boolean | Promise<boolean>): AsyncGenerator<T>;
/**
 * Helper to batch generator chunks
 */
export declare function batch<T>(source: AsyncGenerator<T>, size: number): AsyncGenerator<T[]>;
/**
 * Helper to throttle generator
 */
export declare function throttle<T>(source: AsyncGenerator<T>, delayMs: number): AsyncGenerator<T>;
/**
 * Helper to merge multiple generators
 */
export declare function merge<T>(...sources: AsyncGenerator<T>[]): AsyncGenerator<T>;
/**
 * Create a file stream
 */
export declare function streamFile(filePath: string, _options?: StreamOptions): () => AsyncGenerator<any, void, unknown>;
/**
 * Example usage:
 *
 * import { stream, streamFile, fromArray, pipe } from 'openspeed/plugins/stream';
 *
 * app.use(stream());
 *
 * // Generator function streaming
 * app.get('/stream', (ctx) => {
 *   return ctx.stream(async function* () {
 *     yield 'Hello ';
 *     await new Promise(r => setTimeout(r, 1000));
 *     yield 'World!';
 *   }());
 * });
 *
 * // Server-Sent Events
 * app.get('/events', (ctx) => {
 *   return ctx.streamSSE(async function* () {
 *     let count = 0;
 *     while (count < 10) {
 *       yield { data: { count, timestamp: Date.now() } };
 *       await new Promise(r => setTimeout(r, 1000));
 *       count++;
 *     }
 *   }());
 * });
 *
 * // JSON streaming (NDJSON)
 * app.get('/data', (ctx) => {
 *   return ctx.streamJSON(async function* () {
 *     for (let i = 0; i < 100; i++) {
 *       yield { id: i, value: Math.random() };
 *     }
 *   }());
 * });
 *
 * // File streaming
 * app.get('/file', (ctx) => {
 *   return ctx.stream(streamFile('./large-file.txt')());
 * });
 *
 * // Transform and filter
 * app.get('/filtered', (ctx) => {
 *   const numbers = async function* () {
 *     for (let i = 0; i < 100; i++) yield i;
 *   };
 *
 *   const evens = filter(numbers(), n => n % 2 === 0);
 *   const doubled = pipe(evens, n => n * 2);
 *
 *   return ctx.streamJSON(doubled);
 * });
 */
//# sourceMappingURL=stream.d.ts.map