import type { TaskEvent, ShortTermStore, SeriesResult } from './types.js';
export declare function processSeries(event: TaskEvent, store: ShortTermStore): Promise<SeriesResult>;
/**
 * Collapse accumulate-mode series events into single snapshot events.
 * Used by history endpoint and SSE late-join replay.
 *
 * @param events - Array of events to collapse
 * @param getSeriesLatest - Callback to get latest accumulated value for a series.
 *   For hot tasks, pass engine.getSeriesLatest. If returns null (cold task),
 *   falls back to last event in the events array for that series.
 */
export declare function collapseAccumulateSeries(events: TaskEvent[], getSeriesLatest: (taskId: string, seriesId: string) => Promise<TaskEvent | null>): Promise<TaskEvent[]>;
//# sourceMappingURL=series.d.ts.map