import type { StreamChunk } from '@n8n/agents';
import type { AgentSseEvent } from '@n8n/api-types';
import type { Response } from 'express';
export type FlushableResponse = Response & {
    flush?: () => void;
};
export declare function initSseStream(res: FlushableResponse): {
    send: (event: AgentSseEvent) => void;
    onChunk: (chunk: StreamChunk) => void;
    abortSignal: AbortSignal;
    close: () => void;
};
export declare function emitChunkEvents(chunk: StreamChunk, send: (event: AgentSseEvent) => void): void;