/** * NestJS Streaming Controller * * SSE streaming controller for NestJS applications. * Provides the /events/stream endpoint for real-time updates. * * @example * ```typescript * // Automatically included when using StreamingModule * @Module({ * imports: [StreamingModule.forRoot()], * }) * export class AppModule {} * * // Or import directly for custom routing * @Module({ * controllers: [StreamingController], * providers: [{ provide: STREAM_SERVER, useValue: streamServer }], * }) * export class CustomStreamingModule {} * ``` */ import type { Request, Response } from 'express'; import type { StreamServer } from '../../events/streaming/StreamServer'; /** * Injection token for StreamServer */ export declare const STREAM_SERVER: unique symbol; /** * StreamingController - NestJS SSE endpoint controller * * Handles GET /events/stream requests using the StreamServer's NestJS adapter. */ export declare class StreamingController { private readonly streamServer; constructor(streamServer: StreamServer); /** * SSE streaming endpoint * * Clients connect to this endpoint to receive real-time updates. * Supports channel subscription via query params: ?channels=uploads,system * * @param req - NestJS/Express request * @param res - NestJS/Express response */ stream(req: Request, res: Response): Promise; } //# sourceMappingURL=StreamingController.d.ts.map