import type { AgentBridge, AgentBridgeConfig, BridgeMessage, BridgeTransport } from '../types/agent-bridge.js';
import { InMemoryBridgeTransport } from './in-memory-transport.js';
export { InMemoryBridgeTransport };
export declare class InMemoryAgentBridge implements AgentBridge {
    readonly agentId: string;
    readonly coordinatorId: string;
    private readonly transport;
    private readonly subscriptions;
    private readonly pendingRequests;
    private stopped;
    private timeoutMs;
    /** Guards request() so concurrent calls on the same id can't silently overwrite. */
    private readonly inflightGuards;
    /** Stores the transport unsubscribe function so it can be called on stop(). */
    private _transportUnsubscribe?;
    constructor(config: AgentBridgeConfig, transport: BridgeTransport);
    send(msg: BridgeMessage): Promise<void>;
    broadcast(msg: BridgeMessage): Promise<void>;
    subscribe(handler: (msg: BridgeMessage) => void | Promise<void>): () => void;
    request<T>(msg: BridgeMessage, timeoutMs?: number): Promise<BridgeMessage<T>>;
    stop(): Promise<void>;
}
export declare function createMessage<T = unknown>(type: BridgeMessage['type'], from: string, payload: T, to?: string | undefined): BridgeMessage<T>;
//# sourceMappingURL=agent-bridge.d.ts.map