/** * Express Framework Adapter * * Framework adapter for Express.js and compatible frameworks (Fastify, Koa, etc.). * Converts Express req/res to Web Request/Response and handles SSE streaming. * * @example * ```typescript * import express from 'express'; * import { streamServer } from './stream'; * * const app = express(); * app.get('/events/stream', streamServer.getHandler('express')); * ``` */ import type { FrameworkAdapterConfig, FrameworkHandlerOptions, CoreRequestHandler, ExpressRequest, ExpressHandler } from '@plyaz/types/core'; import { BaseFrameworkAdapter } from './BaseFrameworkAdapter'; /** * ExpressFrameworkAdapter - Express/Fastify adapter * * Features: * - Converts Express req/res to Web Request/Response * - Handles SSE streaming to Express response * - Manages connection cleanup on client disconnect * - Compatible with Express, Fastify, Koa (with adapters) * * @example * ```typescript * const adapter = new ExpressFrameworkAdapter(); * const handler = adapter.createHandler(streamServer.handleRequest); * app.get('/stream', handler); * ``` */ export declare class ExpressFrameworkAdapter extends BaseFrameworkAdapter { readonly framework: "express"; constructor(config?: FrameworkAdapterConfig); /** * Create Express route handler. * * @param handleRequest - Core request handler from StreamServer * @param options - Handler options * @returns Express route handler function */ createHandler(handleRequest: CoreRequestHandler, options?: FrameworkHandlerOptions): ExpressHandler; /** * Convert Express request to Web Request. * * @param req - Express request object * @returns Web Request object */ convertRequest(req: ExpressRequest): Request; /** * Handle Web Response and stream to Express response. * * @param response - Web Response from core handler * @param _req - Original Express request (unused) * @param res - Express response object */ handleResponse(response: Response, _req: unknown, res: unknown): Promise; } //# sourceMappingURL=ExpressFrameworkAdapter.d.ts.map