import type { ContextOperationRequest, StoredStreamChunk, StreamReference } from '../context.ts';
import type { EngineInternals } from './internals.ts';
type StreamOperation = Extract<ContextOperationRequest, {
    type: 'stream';
}>;
export type StreamOperationCallbacks = {
    runOperationWithResult: (workflowId: string, operation: StreamOperation, execute: () => Promise<unknown>) => Promise<void>;
    handleCleanupError: (source: string, error: unknown, workflowId?: string) => void;
};
export declare function getStreamChunksFromInternals(internals: EngineInternals, workflowId: string, key: string, options?: {
    after?: number;
}): Promise<StoredStreamChunk[]>;
export declare function processStreamOperation(internals: EngineInternals, workflowId: string, operation: StreamOperation, callbacks: StreamOperationCallbacks): Promise<void>;
export declare function createStreamReferenceFromInternals(internals: EngineInternals, workflowId: string, operation: StreamOperation, callbacks: Pick<StreamOperationCallbacks, 'handleCleanupError'>): Promise<StreamReference>;
export declare function writeStreamChunksFromInternals(internals: EngineInternals, workflowId: string, operation: StreamOperation, asyncGenerator: AsyncGenerator<unknown, void, unknown>, writtenKeys: string[]): Promise<{
    chunkCount: number;
    totalSizeBytes: number;
}>;
export declare function cleanupStreamChunksFromInternals(internals: EngineInternals, workflowId: string, key: string, writtenKeys: string[], callbacks: Pick<StreamOperationCallbacks, 'handleCleanupError'>): Promise<void>;
export {};