/** * 会话消息出口实现:按 sessionId 维护消费者集合,emit 时扇出到该会话所有消费者。 */ import type { SessionMessage, SessionMessageConsumer } from "./types.js"; export declare class SessionOutlet { private readonly consumersBySession; /** * 向指定会话注册消费者;返回取消注册函数。 */ registerConsumer(sessionId: string, consumer: SessionMessageConsumer): () => void; /** * 向指定会话发送消息;将 sessionId、timestamp 注入后扇出到该会话所有消费者。 */ emit(sessionId: string, message: Omit): void; }