import type { ResourceIdentifier, ActionOrActionTupleFromAction, AnyAction, IOEvents, MovexClient, SanitizedMovexClient } from 'movex-core-util';
import { type ConnectionToMaster } from './ConnectionToMaster';
/**
 * This handles the connection with Master per ResourceType
 */
export declare class ConnectionToMasterResources<TState, TAction extends AnyAction, TResourceType extends string> {
    private connectionToMaster;
    private fwdActionEventPubsy;
    private reconciliatoryActionEventPubsy;
    private subscriberAddedEventPubsy;
    private subscriberRemovedEventPubsy;
    private unsubscribers;
    constructor(resourceType: TResourceType, connectionToMaster: ConnectionToMaster<TState, TAction, TResourceType, {}>);
    create(resourceType: TResourceType, resourceState: TState, resourceId?: string): import("ts-async-results").AsyncResultWrapper<import("movex-core-util").MovexClientResourceShape<TResourceType, TState>, unknown>;
    addResourceSubscriber(rid: ResourceIdentifier<TResourceType>): import("ts-async-results").AsyncResultWrapper<import("movex-core-util").MovexClientResourceShape<TResourceType, TState>, unknown>;
    getState(rid: ResourceIdentifier<TResourceType>): import("ts-async-results").AsyncResultWrapper<import("movex-core-util").CheckedState<TState>, unknown>;
    getSubscribers(rid: ResourceIdentifier<TResourceType>): import("ts-async-results").AsyncResultWrapper<Record<string, Pick<MovexClient<import("movex-core-util").UnknownRecord>, "id" | "info">>, unknown>;
    getResource(rid: ResourceIdentifier<TResourceType>): import("ts-async-results").AsyncResultWrapper<import("movex-core-util").MovexClientResourceShape<TResourceType, TState>, unknown>;
    emitAction(rid: ResourceIdentifier<TResourceType>, actionOrActionTuple: ActionOrActionTupleFromAction<TAction>): import("ts-async-results").AsyncResultWrapper<({
        type: "ack";
        nextChecksum: string;
    } | {
        type: "masterActionAck";
        nextCheckedAction: import("movex-core-util").ToCheckedAction<TAction>;
    } | ({
        type: "reconciliation";
    } & import("movex-core-util").CheckedReconciliatoryActions<TAction>)) & {
        masterContext: import("movex-core-util").MovexMasterContext;
    }, string>;
    onFwdAction(rid: ResourceIdentifier<TResourceType>, fn: (p: Parameters<IOEvents<TState, TAction, TResourceType>['onFwdAction']>[0]) => void): () => void;
    onReconciliatoryActions(rid: ResourceIdentifier<TResourceType>, fn: (p: Parameters<IOEvents<TState, TAction, TResourceType>['onReconciliateActions']>[0]) => void): () => void;
    onSubscriberAdded(rid: ResourceIdentifier<TResourceType>, fn: (clientId: SanitizedMovexClient) => void): () => void;
    onSubscriberRemoved(rid: ResourceIdentifier<TResourceType>, fn: (clientId: MovexClient['id']) => void): () => void;
    destroy(): void;
}