import { FlinkApp, FlinkContext, FlinkPlugin } from "@flink-app/flink";
import { StreamHandler, StreamHandlerModule, StreamingPluginOptions, StreamingRouteProps } from "./types";
/**
 * Streaming plugin for Flink Framework
 * Provides SSE and NDJSON streaming support
 */
export declare class StreamingPlugin implements FlinkPlugin {
    id: string;
    private app?;
    private options;
    constructor(options?: StreamingPluginOptions);
    init(app: FlinkApp<any>): Promise<void>;
    /**
     * Register a streaming handler from a module (preferred DX)
     *
     * @example
     * ```typescript
     * import * as GetChatStream from "./handlers/streaming/GetChatStream";
     *
     * // After app.start()
     * streaming.registerStreamHandler(GetChatStream);
     * ```
     */
    registerStreamHandler<Ctx extends FlinkContext, T = any>(handlerModule: StreamHandlerModule<Ctx, T>): void;
    /**
     * Register a streaming handler with explicit handler and route props
     *
     * @example
     * ```typescript
     * streaming.registerStreamHandler(
     *   async ({ stream }) => {
     *     stream.write({ message: "Hello" });
     *     stream.end();
     *   },
     *   { path: "/stream", skipAutoRegister: true }
     * );
     * ```
     */
    registerStreamHandler<Ctx extends FlinkContext, T = any>(handler: StreamHandler<Ctx, T>, routeProps: StreamingRouteProps): void;
}
/**
 * Factory function to create streaming plugin
 */
export declare function streamingPlugin(options?: StreamingPluginOptions): StreamingPlugin;
//# sourceMappingURL=StreamingPlugin.d.ts.map