/**
 * StreamManager class
 * Manages multiple event streams and their connections to workers
 */
import { EventStream } from "./event-stream.js";
import { StreamEventMessage, StreamOptions } from "../types/events.js";
import { WorkerAdapter } from "./worker-adapter.js";
/**
 * StreamManager class
 * Manages multiple event streams and their connections to workers
 */
export declare class StreamManager {
    /** Active streams */
    private streams;
    /** Worker-stream assignments */
    private workerStreams;
    /**
     * StreamManager constructor
     */
    constructor();
    /**
     * Create new stream
     * @param worker Worker adapter
     * @param options Stream options
     * @returns New event stream
     */
    createStream<T = any>(worker: WorkerAdapter, options?: StreamOptions): EventStream<T>;
    /**
     * Handle worker message
     * @param workerId Worker ID
     * @param message Message from worker
     */
    handleWorkerMessage(workerId: string, message: StreamEventMessage): void;
    /**
     * Assign worker to stream
     * @param workerId Worker ID
     * @param streamId Stream ID
     */
    private assignWorkerToStream;
    /**
     * Find worker for stream
     * @param streamId Stream ID
     * @returns Worker ID or undefined
     */
    private findWorkerForStream;
    /**
     * Remove stream
     * @param streamId Stream ID
     */
    private removeStream;
    /**
     * Close all streams
     */
    closeAllStreams(): Promise<void>;
    /**
     * Get stream count
     */
    getStreamCount(): number;
    /**
     * Get worker count
     */
    getWorkerCount(): number;
}