import type { McpModuleOptions } from '@nest-mcp/common';
import { type OnModuleDestroy } from '@nestjs/common';
import { McpRegistryService } from '../../discovery/registry.service';
import { McpContextFactory } from '../../execution/context.factory';
import { McpExecutorService } from '../../execution/executor.service';
import { ExecutionPipelineService } from '../../execution/pipeline.service';
import { ResourceSubscriptionManager } from '../../subscription/resource-subscription.manager';
import { TaskManager } from '../../task/task.manager';
export declare class StreamableHttpService implements OnModuleDestroy {
    private readonly options;
    private readonly registry;
    private readonly executor;
    private readonly pipeline;
    private readonly contextFactory;
    private readonly subscriptionManager?;
    private readonly taskManager?;
    private readonly logger;
    private readonly transports;
    private readonly servers;
    private readonly contexts;
    /** SDK handles per session, keyed by item name/uri for removal. */
    private readonly sdkHandles;
    private readonly registryListeners;
    constructor(options: McpModuleOptions, registry: McpRegistryService, executor: McpExecutorService, pipeline: ExecutionPipelineService, contextFactory: McpContextFactory, subscriptionManager?: ResourceSubscriptionManager | undefined, taskManager?: TaskManager | undefined);
    get isStateless(): boolean;
    handlePostRequest(req: unknown, res: unknown): Promise<void>;
    handleGetRequest(req: unknown, res: unknown): Promise<void>;
    handleDeleteRequest(req: unknown, res: unknown): Promise<void>;
    private buildTransportOptions;
    private handleStatelessPost;
    private handleStatefulPost;
    private createAndConnectServer;
    private subscribeToRegistryEvents;
    private cleanupSession;
    onModuleDestroy(): Promise<void>;
}
//# sourceMappingURL=streamable.service.d.ts.map