Server IP : 150.95.80.236 / Your IP : 52.15.239.254 Web Server : Apache System : Linux host-150-95-80-236 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : social-telecare ( 10000) PHP Version : 7.4.33 Disable Function : opcache_get_status MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/vhosts/pcu.in.th/api-uat.pcu.in.th/node_modules/@nestjs/core/router/ |
Upload File : |
/// <reference types="node" /> /// <reference types="node" /> /// <reference types="node" /> import { MessageEvent } from '@nestjs/common/interfaces'; import { IncomingMessage, OutgoingHttpHeaders } from 'http'; import { Transform } from 'stream'; export type AdditionalHeaders = Record<string, string[] | string | number | undefined>; interface ReadHeaders { getHeaders?(): AdditionalHeaders; } interface WriteHeaders { writableEnded?: boolean; writeHead?(statusCode: number, reasonPhrase?: string, headers?: OutgoingHttpHeaders): void; writeHead?(statusCode: number, headers?: OutgoingHttpHeaders): void; flushHeaders?(): void; } export type WritableHeaderStream = NodeJS.WritableStream & WriteHeaders; export type HeaderStream = WritableHeaderStream & ReadHeaders; /** * Adapted from https://raw.githubusercontent.com/EventSource/node-ssestream * Transforms "messages" to W3C event stream content. * See https://html.spec.whatwg.org/multipage/server-sent-events.html * A message is an object with one or more of the following properties: * - data (String or object, which gets turned into JSON) * - type * - id * - retry * * If constructed with a HTTP Request, it will optimise the socket for streaming. * If this stream is piped to an HTTP Response, it will set appropriate headers. */ export declare class SseStream extends Transform { private lastEventId; constructor(req?: IncomingMessage); pipe<T extends WritableHeaderStream>(destination: T, options?: { additionalHeaders?: AdditionalHeaders; end?: boolean; }): T; _transform(message: MessageEvent, encoding: string, callback: (error?: Error | null, data?: any) => void): void; /** * Calls `.write` but handles the drain if needed */ writeMessage(message: MessageEvent, cb: (error: Error | null | undefined) => void): void; } export {};