/** 可靠事件入口用于查询和提交已成功投递的事件身份。 */ export interface EventDeliveryStore { has(key: TKey): boolean; commit(key: TKey): void; } /** * 合并并发重投,并且只在业务投递完整成功后提交事件身份。 * * 首个调用返回 `true`;等待同一次投递的并发调用以及后续重投返回 `false`。 * 投递失败会原样传播给全部等待者,且不会污染去重状态。 */ export declare class ReliableEventIngress { private readonly delivered; private readonly pending; constructor(delivered?: EventDeliveryStore); deliver(key: TKey, dispatch: () => void | PromiseLike): Promise; }