import { type DataBatchRequestPayload, type DataBatchResponseItem } from '../../data-platform/index.js';
export { toHeaderRecord } from '../../headers.js';
export declare function normalizeBatchPath(pathname: string | undefined): `/${string}`;
type ParsedBatchRequestPayload = Omit<DataBatchRequestPayload, 'items'> & {
    items: unknown[];
};
export declare function isBatchRequestPayload(value: unknown): value is ParsedBatchRequestPayload;
export declare function createBatchValidationResponse(message: string, status?: number): Response;
export declare function prepareJsonRequestBody(request: Request): Promise<Request | Response>;
export declare function toBatchItemError(id: string, status: number, message: string): DataBatchResponseItem;
declare const BatchItemTimeoutError_base: new <A extends Record<string, any> = {}>(args: import("effect/Types").VoidIfEmpty<{ readonly [P in keyof A as P extends "_tag" ? never : P]: A[P]; }>) => import("effect/Cause").YieldableError & {
    readonly _tag: "BatchItemTimeoutError";
} & Readonly<A>;
export declare class BatchItemTimeoutError extends BatchItemTimeoutError_base<{
    readonly message: string;
}> {
    constructor(message: string);
}
export declare function promiseWithTimeout<T>(effect: Promise<T>, timeoutMs: number, onTimeout?: (error: BatchItemTimeoutError) => void): Promise<T>;
export declare function mapWithConcurrency<TItem, TResult>(items: readonly TItem[], concurrency: number, mapper: (item: TItem, index: number) => Promise<TResult>): Promise<TResult[]>;