import { Subject } from "rxjs";
export * from "./debugger";
import { InternalCodeNode, NodeInputs, NodeOutputs, NodeInstanceError, NodeState, InternalNode } from "../node";
import { OMap, OMapF } from "../common";
import { Debugger } from "./debugger";
export type SubjectMap = OMapF<Subject<any>>;
export type ExecutionState = Map<string, any>;
export type CancelFn = () => void;
export type InnerExecuteFn = (node: InternalNode, args: NodeInputs, outputs: NodeOutputs, insId: string) => CancelFn;
export type CodeExecutionData = {
    node: InternalCodeNode;
    inputs: NodeInputs;
    outputs: NodeOutputs;
    _debugger?: Debugger;
    /**
     * If the node is an instance of another node, this is the id of the instance.
     * If the node is the root node, this is "__root".
     * Used for debugger events and state namespacing
     */
    insId: string;
    /**
     * A full path of ancestor insIds, separated by dots.
     * Used for debugger events and state namespacing
     */
    ancestorsInsIds?: string;
    extraContext?: Record<string, any>;
    mainState: OMap<NodeState>;
    onError: (err: any) => void;
    onBubbleError: (err: any) => void;
    onCompleted?: (data: any) => void;
    onStarted?: () => void;
};
export declare const INNER_STATE_SUFFIX = "_inner";
export declare const INPUTS_STATE_SUFFIX = "_inputs";
export type ExecuteFn = (params: ExecuteParams) => CancelFn;
export type ExecuteParams = {
    node: InternalNode;
    inputs: NodeInputs;
    outputs: NodeOutputs;
    _debugger?: Debugger;
    insId?: string;
    ancestorsInsIds?: string;
    mainState?: OMap<NodeState>;
    onBubbleError?: (err: NodeInstanceError) => void;
    extraContext?: Record<string, any>;
    onCompleted?: (data: any) => void;
    onStarted?: () => void;
};
export declare const ROOT_INS_ID = "__root";
export declare const GLOBAL_STATE_NS = "____global";
export declare const execute: ExecuteFn;
//# sourceMappingURL=index.d.ts.map