/*!
 * Copyright (c) Microsoft Corporation and contributors. All rights reserved.
 * Licensed under the MIT License.
 */
import { TypedEventEmitter } from "@fluid-internal/client-utils";
import type { IDisposable } from "@fluidframework/core-interfaces";
import type { ConnectionMode } from "@fluidframework/driver-definitions";
import type { IDocumentDeltaConnection, IDocumentDeltaConnectionEvents, IClientConfiguration, IConnected, IDocumentMessage, ISignalClient, ITokenClaims, ISequencedDocumentMessage, ISignalMessage } from "@fluidframework/driver-definitions/internal";
import type { FileDeltaStorageService } from "./fileDeltaStorageService.js";
/**
 * Replay service used to play ops using the delta connection.
 * @internal
 */
export declare class Replayer {
    private readonly deltaConnection;
    private readonly documentStorageService;
    private currentReplayOp;
    constructor(deltaConnection: ReplayFileDeltaConnection, documentStorageService: FileDeltaStorageService);
    get currentReplayedOp(): number;
    set currentReplayedOp(op: number);
    get ops(): readonly Readonly<ISequencedDocumentMessage>[];
    /**
     * Replay the ops upto a certain number.
     * @param replayTo - The last op number to be replayed.
     */
    replay(replayTo: number): number;
    private isDoneFetch;
    private emit;
}
/**
 * @internal
 */
export declare class ReplayFileDeltaConnection extends TypedEventEmitter<IDocumentDeltaConnectionEvents> implements IDocumentDeltaConnection, IDisposable {
    details: IConnected;
    /**
     * Mimic the delta connection to replay ops on it.
     *
     * @param documentDeltaStorageService - The delta storage service to get ops from.
     * @returns Document delta connection.
     */
    static create(documentDeltaStorageService: FileDeltaStorageService): Promise<ReplayFileDeltaConnection>;
    readonly maxMessageSize: number;
    private readonly replayer;
    constructor(details: IConnected, documentDeltaStorageService: FileDeltaStorageService);
    getReplayer(): Replayer;
    get clientId(): string;
    get mode(): ConnectionMode;
    get claims(): ITokenClaims;
    get existing(): boolean;
    get version(): string;
    get initialMessages(): ISequencedDocumentMessage[];
    get initialSignals(): ISignalMessage[];
    get initialClients(): ISignalClient[];
    get serviceConfiguration(): IClientConfiguration;
    submit(documentMessages: IDocumentMessage[]): void;
    submitSignal(message: any): Promise<void>;
    private _disposed;
    get disposed(): boolean;
    dispose(): void;
}
//# sourceMappingURL=fileDocumentDeltaConnection.d.ts.map