import { EventClient } from "./eventDbHelpers";
import { GenericEventBase, GenericEventInput } from "./schemaHelpers";
import { EventFromType, StreamOptionsForEvents } from "./utils";
export declare class MultiStreamProjectionBase<EventType extends string, Event extends GenericEventBase<EventType>, Client extends EventClient, V extends Record<string, unknown>, ET extends EventType = EventType, E extends EventFromType<ET, Event> = EventFromType<ET, Event>> {
    protected eventsClient: Client;
    private loadExistingProjection;
    /** The type of this projection, used to look up the projection in the database */
    protected get projectionType(): string;
    protected _events?: Promise<(E | GenericEventInput<E>)[]>;
    protected _stagedEvents: (E | GenericEventInput<E>)[];
    private _savedProjection?;
    constructor(eventsClient: Client, loadExistingProjection?: boolean);
    protected get savedProjection(): Promise<{
        data: V;
        latestEventId: string;
    } | undefined>;
    private getEventsAfterIdentifiers;
    private get events();
    protected projectionEvents(): Promise<(E | GenericEventInput<E>)[]>;
    /** Stage events without saving them to the database */
    apply(events: GenericEventInput<E>[]): this;
    /** Replace internal events array without affecting database */
    fromHistory(events: E[]): this;
    /** Clear cached events and projection to force fresh data on next access */
    refresh(): this;
    /** Reduce events with a custom reducer function */
    protected reduceEvents<T>(reducer: (acc: T, event: E | GenericEventInput<E>) => T, initialValue: T): Promise<T>;
    /** Check if there are events to save */
    isDirty(): Promise<boolean>;
    /** Save the projection only if it has events to save, returns true if saved */
    saveIfDirty(overwrite?: boolean): Promise<boolean>;
    /** Save the projection to the database */
    saveProjection(overwrite?: boolean): Promise<{
        id: string;
        data: unknown;
        type: string;
        latestEventId: string;
        status: "created" | "updated" | "skipped";
    }>;
    /** Get a value from the saved projection or return the fallback */
    protected fromProjectionOrDefault<T>(key: keyof V, fallback: T): Promise<T>;
    get id(): string;
    protected getStreamOptions(): Promise<StreamOptionsForEvents<E, ET>[]> | StreamOptionsForEvents<E, ET>[];
    asJson(): Promise<V>;
}