import { AckCommitsEvent, Commit, CommitsEvent, ErrorCode, OnRemoteEventFn, Remote, RemoteSyncInfo, SyncEvent } from '../types';
import { MemoryStore } from './MemoryStore';
export declare class MemoryRemote<CommitMetadata, Delta, Presence> implements Remote<CommitMetadata, Delta, Presence> {
    private readonly store;
    private readonly userId;
    private readonly onEvent;
    private readonly remoteQueue;
    private closed;
    private readonly clientStoreId;
    constructor(store: MemoryStore<CommitMetadata, Delta, Presence>, userId: string, { lastSyncCursor, localStoreId }: RemoteSyncInfo, onEvent: OnRemoteEventFn<CommitMetadata, Delta, Presence>);
    private handle;
    send(event: SyncEvent<CommitMetadata, Delta, Presence>): void;
    private receive;
    protected sendInitialEvents(lastSyncCursor: string | undefined): Promise<void>;
    shutdown(): Promise<void>;
    fail(message: string, code: ErrorCode, reconnect?: boolean): void;
    protected handleAsError(code: ErrorCode): (error: Error) => void;
    protected addCommits(commits: readonly Commit<CommitMetadata, Delta>[]): Promise<AckCommitsEvent<CommitMetadata>>;
    protected broadcast(event: SyncEvent<CommitMetadata, Delta, Presence>): Promise<void>;
    protected getCommits(lastSyncCursor: string | undefined): AsyncIterableIterator<CommitsEvent<CommitMetadata, Delta, Presence>>;
}