/** * Files Stream Endpoint * * Stream endpoint for file-related real-time events. * Handles upload, download, and document generation progress. * * @example * ```typescript * // Register in StreamRegistry * await StreamRegistry.initialize({ * broadcaster: streamServer.getBroadcaster(), * endpoints: [ * { endpoint: FilesStreamEndpoint, config: { enabled: true } }, * ], * }); * ``` */ import { BaseStreamEndpoint } from '../../../events/streaming/base/BaseStreamEndpoint'; import type { BaseChannelController } from '../../../events/streaming/channels/BaseChannelController'; import type { StreamEndpointConfig, StreamEndpointCreateOptions } from '@plyaz/types/core'; /** * FilesStreamEndpoint - Handles file streaming events * * Channels managed: * - `upload:{fileId}` - Per-file upload progress * - `uploads` - All uploads broadcast * - `download:{fileId}` - Per-file download progress * - `downloads` - All downloads broadcast * - `generate:{templateId}` - Per-template generation progress * - `generations` - All generations broadcast */ export declare class FilesStreamEndpoint extends BaseStreamEndpoint { /** Static endpoint key for registry lookup */ static readonly endpointKey = "files"; /** * Create channel controller for this endpoint. */ protected createChannelController(): BaseChannelController; /** * Initialize event subscriptions. * Called by StreamRegistry during initialization. */ initialize(): void; /** * Static factory method for creating endpoint instances. * * @param config - Endpoint configuration * @param options - Create options (broadcaster, auth, etc.) * @returns Promise resolving to endpoint instance */ static create(config: StreamEndpointConfig, options: StreamEndpointCreateOptions): Promise; } //# sourceMappingURL=FilesStreamEndpoint.d.ts.map