import { type Observable } from "rxjs"; import type { Event } from "../event"; import type { PostMessage, RpcClient } from "./types"; /** * Internal factory function to create the recursive RPC client proxy. * * @remarks * This function recursively builds the client object based on the provided configuration. * It handles the logic for sending requests, listening for replies, and managing subscriptions. * * @template Config - The type of the current level of configuration. * @param postMessage - Function to send messages to the worker. * @param incoming$ - Observable stream of incoming messages from the worker. * @returns The constructed client object for the current level. */ export declare function createRpcProxy(postMessage: PostMessage, incoming$: Observable>): RpcClient;