import { type CustomizationCapabilityFinding, type CustomizationResourceLimits, type HistoricalDatasetInput, type HistoricalRecordDisposition, type PreparedHistoricalObservation } from "@actuarial-ts/core";
import { type CustomizationExternalStateAdapter } from "./customizationExternalState.js";
export type PreparedHistoryStreamEvent = {
    readonly kind: "observation";
    readonly observation: PreparedHistoricalObservation;
} | {
    readonly kind: "disposition";
    readonly disposition: HistoricalRecordDisposition;
} | {
    readonly kind: "finding";
    readonly finding: CustomizationCapabilityFinding;
};
/**
 * Sorts raw revisions in host-owned state and prepares one claim partition at
 * a time. Retained SDK state is bounded by maximumPartitionRecords; oversized
 * claims fail rather than silently spilling or dropping observations.
 */
export declare function streamPreparedHistoricalDataset(input: {
    readonly runId: string;
    readonly header: Omit<HistoricalDatasetInput, "records">;
    readonly records: AsyncIterable<unknown> | Iterable<unknown>;
    readonly adapter: CustomizationExternalStateAdapter;
    readonly limits: CustomizationResourceLimits;
    readonly signal?: AbortSignal;
}): AsyncGenerator<PreparedHistoryStreamEvent>;
//# sourceMappingURL=customizationHistoryStream.d.ts.map