import type express from 'express';
import { type LexValue, l } from '@atproto/lex';
import type { HandlerPipeThrough } from '@atproto/xrpc-server';
import type { AppContext } from '../context.js';
import type { HandlerResponse, LocalRecords, MungeFn } from './types.js';
export declare const getLocalLag: (local: LocalRecords) => number | undefined;
export declare const pipethroughReadAfterWrite: <M extends (l.Query | l.Procedure) & {
    output: l.Payload<`application/json`, l.Schema<LexValue>>;
}>(ctx: AppContext, reqCtx: {
    req: express.Request;
    auth: {
        credentials: {
            did: string;
        };
    };
}, ns: l.Main<M>, munge: MungeFn<l.InferMethodOutputBody<M>>) => Promise<HandlerResponse<l.InferMethodOutputBody<M>> | HandlerPipeThrough>;
export declare const formatMungedResponse: <T>(body: T, lag?: number) => HandlerResponse<T>;
//# sourceMappingURL=util.d.ts.map