import type { AbortSignalLike } from "@azure/abort-controller"; import type { WebPubSubResult } from "./models/index.js"; export interface AckRegistration { ackId: number; wait(abortSignal?: AbortSignalLike): Promise; } /** * Manages ack id generation and pending ack entries. */ export declare class AckManager { private readonly _ackEntries; private _ackId; constructor(initialAckId?: number); registerAck(ackId?: number): AckRegistration; resolveAck(ackId: number, result: WebPubSubResult): boolean; rejectAck(ackId: number, reason: unknown): boolean; discard(ackId: number): void; rejectAll(createReason: (ackId: number) => unknown): void; private _waitForEntry; private _generateAckId; } //# sourceMappingURL=ackManager.d.ts.map