Class Streamer

Hierarchy

Streamer

Index

Constructors

Properties

blockedStreamLimit connection eventParser streamReader

Methods

addData eventGenerator fillStream registerEvent defaultStreamer

Constructors

constructor

new Streamer(connection: HttpConnection, streamReader: EventStreamReader, blockedStreamLimit: number): Streamer
Parameters
- connection: HttpConnection
- streamReader: EventStreamReader
- blockedStreamLimit: number
Returns Streamer
- Defined in src/sse/streamer.ts:17

Properties

`Private` blockedStreamLimit

blockedStreamLimit: number

`Private` connection

connection: HttpConnection

`Private` eventParser

eventParser: EventParser

`Private` streamReader

streamReader: EventStreamReader

Methods

`Private` addData

addData(stream: AsyncGenerator<RawEvent, any, unknown>, data: RawEvent): Promise<void>
Parameters
- stream: AsyncGenerator<RawEvent, any, unknown>
- data: RawEvent
Returns Promise<void>
- Defined in src/sse/streamer.ts:77

`Private` eventGenerator

eventGenerator(): AsyncGenerator<Uint8Array, any, unknown>
Returns AsyncGenerator<Uint8Array, any, unknown>
- Defined in src/sse/streamer.ts:92

fillStream

fillStream(lastEventID: number, stream: AsyncGenerator<RawEvent, any, unknown>, errorsCh: ((err: Error) => void)): Promise<void>
Parameters
- lastEventID: number
- stream: AsyncGenerator<RawEvent, any, unknown>
- errorsCh: ((err: Error) => void)
  - - (err: Error): void
    - Parameters
      
      err: Error
      
      Returns void
Returns Promise<void>
- Defined in src/sse/streamer.ts:40

registerEvent

registerEvent(eventType: EventType): void
Parameters
- eventType: EventType
Returns void
- Defined in src/sse/streamer.ts:36

`Static` defaultStreamer

defaultStreamer(url: string): Streamer
Parameters
- url: string
Returns Streamer
- Defined in src/sse/streamer.ts:28

Generated using TypeDoc