/** * Streaming Module * * Real-time event streaming via SSE/WebSocket. * Structured for future extraction to @plyaz/events package. * * @example * ```ts * import { StreamServer } from '@plyaz/core/events/streaming'; * * // Create stream server with builder pattern * const streamServer = StreamServer.create() * .withAuth(new AnonymousAuthAdapter()) * .withSSE({ heartbeatInterval: 15000 }) * .build(); * * // Next.js App Router * export const GET = streamServer.getHandler('nextjs'); * * // Express * app.get('/stream', streamServer.getHandler('express')); * * // Client-side: Connect to stream * const { connected } = useStreamConnection({ * channels: ['uploads'], * onMessage: (msg) => console.log(msg), * }); * ``` */ export type { StreamConnection, StreamConnectionInfo, StreamTransportType, StreamMessage, StreamProgressData, StreamChannel, ChannelSubscription, StreamAuthResult, StreamAuthAdapterConfig, TokenAuthAdapterConfig, StreamTransportAdapterConfig, StreamBroadcasterConfig, StreamManagerStats, FilesUploadStreamProgress, FilesDownloadStreamProgress, FilesGenerateStreamProgress, FilesStreamProgressData, UseStreamConnectionOptions, UseStreamConnectionResult, } from '@plyaz/types/core'; export { StreamServer, StreamServerBuilder } from './StreamServer'; export type { StreamServerConfig } from './StreamServer'; export { BaseAuthAdapter } from './auth'; export { AnonymousAuthAdapter, TokenAuthAdapter } from './auth'; export { BaseTransportAdapter } from './transports'; export { SSETransportAdapter, WebSocketTransportAdapter } from './transports'; export { BaseFrameworkAdapter, NextJSFrameworkAdapter, ExpressFrameworkAdapter, NestJSFrameworkAdapter, } from './frameworks'; export { StreamConnectionManager } from './StreamConnectionManager'; export { StreamBroadcaster } from './StreamBroadcaster'; export { StreamRegistry } from './StreamRegistry'; export { BaseStreamEndpoint } from './base/BaseStreamEndpoint'; export { BaseChannelController } from './channels/BaseChannelController'; export { FilesStreamEndpoint, FilesChannelController, NotificationsStreamEndpoint, NotificationsChannelController, SystemStreamEndpoint, SystemChannelController, } from './endpoints'; export { MiddlewareChain, createRateLimitMiddleware, cleanupRateLimitTracking, getRateLimitStats, } from './middleware'; export { STREAMING_DEFAULTS, STREAMING_SERVER_CONFIG, STREAMING_CLIENT_CONFIG, STREAMING_BUFFER_CONFIG, STREAMING_PACKAGE_CONFIG, type StreamingDefaults, } from '@plyaz/config/streaming'; //# sourceMappingURL=index.d.ts.map