Class SseClient

Hierarchy

SseClient

Index

Constructors

Properties

consumer consumerErrorHandler consumerErrors eventStream middlewares streamErrorHandler streamErrors streamer workersCount

Methods

logErrors registerHandler registerMiddleware start stop

Constructors

constructor

new SseClient(url: string, workersCount?: number): SseClient
Parameters
- url: string
- workersCount: number = 1
Returns SseClient
- Defined in src/sse/client.ts:20

Properties

`Private` consumer

consumer: Consumer

`Private` consumerErrorHandler

consumerErrorHandler: ((errors: Error[]) => void)

Type declaration

- (errors: Error[]): void
- Parameters
  - errors: Error[]
  Returns void

`Private` consumerErrors

consumerErrors: Error[] = []

`Private` eventStream

eventStream: RawEvent[] = []

`Private` middlewares

middlewares: Middleware[] = []

`Private` streamErrorHandler

streamErrorHandler: ((errors: Error[]) => void)

Type declaration

- (errors: Error[]): void
- Parameters
  - errors: Error[]
  Returns void

`Private` streamErrors

streamErrors: Error[] = []

`Private` streamer

streamer: Streamer

`Private` workersCount

workersCount: number

Methods

`Private` logErrors

logErrors(source: Error[]): void
Parameters
- source: Error[]
Returns void
- Defined in src/sse/client.ts:60

registerHandler

registerHandler(eventType: EventType, handler: HandlerFunc): void
Parameters
- eventType: EventType
- handler: HandlerFunc
Returns void
- Defined in src/sse/client.ts:50

registerMiddleware

registerMiddleware(middleware: Middleware): void
Parameters
- middleware: Middleware
Returns void
- Defined in src/sse/client.ts:46

start

start(lastEventID: number): Promise<void>
Parameters
- lastEventID: number
Returns Promise<void>
- Defined in src/sse/client.ts:31

stop

stop(): void
Returns void
- Defined in src/sse/client.ts:66

Generated using TypeDoc