import type { Awaitable, CommandCatalog, Domain } from './types.js';
export type WorkflowMode = 'parallel' | 'serial' | 'latest' | 'leading' | 'drop';
export interface WorkflowContext {
    readonly signal: AbortSignal;
    delay(milliseconds: number): Promise<void>;
    retry<Result>(operation: (attempt: number) => Awaitable<Result>, options?: RetryOptions): Promise<Result>;
    fork<Result>(operation: (context: WorkflowContext) => Awaitable<Result>): WorkflowTask<Result>;
}
export interface RetryOptions {
    readonly attempts?: number;
    readonly delayMs?: number | ((attempt: number) => number);
    readonly shouldRetry?: (error: unknown, attempt: number) => boolean;
}
export interface WorkflowTask<Result> {
    readonly result: Promise<Result>;
    cancel(reason?: unknown): void;
}
export interface Workflow<Input, Result> {
    start(input: Input): WorkflowTask<Result>;
    cancelAll(reason?: unknown): void;
    active(): number;
}
export declare function forgeWorkflow<Input, Result>(operation: (context: WorkflowContext, input: Input) => Awaitable<Result>, options?: {
    readonly mode?: WorkflowMode;
    readonly debounceMs?: number;
    readonly throttleMs?: number;
}): Workflow<Input, Result>;
export declare function waitForDomain<State, Commands extends CommandCatalog<State>>(domain: Domain<State, Commands>, predicate: (state: Readonly<State>) => boolean, options?: {
    readonly timeoutMs?: number;
    readonly signal?: AbortSignal;
}): Promise<Readonly<State>>;
//# sourceMappingURL=workflows.d.ts.map