Class EventSource

polyfill of browser EventSource relying on Node EventTarget, Node http/https/http2 api, and reader-parser of this package

Hierarchy

BaseEventSource
- EventSource

Index

Constructors

constructor

new EventSource(url: string, eventSourceInitDict?: RequestOptions): Node.EventSource
Parameters
- url: string
- eventSourceInitDict: RequestOptions = {}
Returns Node.EventSource
Overrides BaseEventSource.constructor
- Defined in src/node/EventSource.ts:12

Properties

`Private` #eventSourceInitDict

#eventSourceInitDict: RequestOptions

`Private` #reconnectionTime

#reconnectionTime: number = 3000

`Private` `Optional` #request

#request?: ClientRequest

`Private` `Optional` #response

#response?: IncomingMessage

`Protected` _readyState

_readyState: undefined | number

onerror

onerror: undefined | ((event: Event) => void)

onmessage

onmessage: undefined | ((event: Event) => void)

onopen

onopen: undefined | ((event: Event) => void)

`Readonly` url

url: string

`Static` `Readonly` CLOSED

CLOSED: CLOSED = ReadyState.CLOSED

`Static` `Readonly` CONNECTING

CONNECTING: CONNECTING = ReadyState.CONNECTING

`Static` `Readonly` OPEN

OPEN: OPEN = ReadyState.OPEN

Accessors

readyState

get readyState(): undefined | number
Returns undefined | number
Inherited from BaseEventSource.readyState
- Defined in src/BaseEventSource.ts:61

Methods

addEventListener

addEventListener(type: string, listener: EventListener | EventListenerObject, options?: boolean | AddEventListenerOptions): void
Adds a new handler for the type event. Any given listener is added only once per type and per capture option value.

If the once option is true, the listener is removed after the next time a type event is dispatched.

The capture option is not used by Node.js in any functional way other than tracking registered event listeners per the EventTarget specification. Specifically, the capture option is used as part of the key when registering a listener. Any individual listener may be added once with capture = false, and once with capture = true.
Parameters
- type: string
- listener: EventListener | EventListenerObject
- Optional options: boolean | AddEventListenerOptions
Returns void
Inherited from BaseEventSource.addEventListener
- Defined in node_modules/@types/node/ts4.8/dom-events.d.ts:63

`Protected` `Readonly` cleaning

cleaning(): void
MUST be implemented by child class

Example
```
protected cleaning() {
  // clean resources
  // ex
  this.#request?.destroy();
  this.#request = undefined;
}
```
Returns void
Overrides BaseEventSource.cleaning
- Defined in src/node/EventSource.ts:55

close

close(): void
Returns void
Inherited from BaseEventSource.close
- Defined in src/BaseEventSource.ts:70

dispatchEvent

dispatchEvent(event: Event): boolean
Dispatches a synthetic event event to target and returns true if either event's cancelable attribute value is false or its preventDefault() method was not invoked, and false otherwise.
Parameters
- event: Event
Returns boolean
Inherited from BaseEventSource.dispatchEvent
- Defined in node_modules/@types/node/ts4.8/dom-events.d.ts:69

`Protected` handleInvalidResponse

handleInvalidResponse(): void
Protected
build an error attach to an event error and dispatch the event

Returns void
Inherited from BaseEventSource.handleInvalidResponse
- Defined in src/BaseEventSource.ts:118

`Protected` init

init(url: string): void
MUST be implemented by child class
Parameters
- url: string
Returns void
Overrides BaseEventSource.init
- Defined in src/node/EventSource.ts:18

`Protected` initStreamAdaptor

initStreamAdaptor(stream: TransformParser, onErrorCleanUp: (() => void)): void
Protected
- listen error on stream to signal in EventTarget way
- listen on data on stream to signal it EventTarget way (message, named event)
Parameters
- stream: TransformParser
- onErrorCleanUp: (() => void)
  - - (): void
    - Returns void
Returns void
Inherited from BaseEventSource.initStreamAdaptor
- Defined in src/BaseEventSource.ts:185

`Protected` isValidResponse

isValidResponse(response: {
headers?: IncomingHttpHeaders;
statusCode?: number;
}): boolean
Protected
Check if response 200 or Content-Type is text/event-stream
Parameters
- response: {
  headers?: IncomingHttpHeaders;
  statusCode?: number;
  }
  - Optional headers?: IncomingHttpHeaders
  - Optional statusCode?: number
Returns boolean
Inherited from BaseEventSource.isValidResponse
- Defined in src/BaseEventSource.ts:104

removeEventListener

removeEventListener(type: string, listener: EventListener | EventListenerObject, options?: boolean | EventListenerOptions): void
Removes the event listener in target's event listener list with the same type, callback, and options.
Parameters
- type: string
- listener: EventListener | EventListenerObject
- Optional options: boolean | EventListenerOptions
Returns void
Inherited from BaseEventSource.removeEventListener
- Defined in node_modules/@types/node/ts4.8/dom-events.d.ts:71

`Protected` signalError

signalError(error: Error): void
Dispatch an event error
Parameters
- error: Error
Returns void
Inherited from BaseEventSource.signalError
- Defined in src/BaseEventSource.ts:143

`Protected` signalEvent

signalEvent(_event: IEvent): void
Check if IEvent is named (prop event: string) Dispatch it
Parameters
- _event: IEvent
Returns void
Inherited from BaseEventSource.signalEvent
- Defined in src/BaseEventSource.ts:169

`Protected` signalMessage

signalMessage(_event: IEvent): void
Dispatch a message with an IEvent and try to dispatch named event from message event
Parameters
- _event: IEvent
Returns void
Inherited from BaseEventSource.signalMessage
- Defined in src/BaseEventSource.ts:156

`Protected` signalOpen

signalOpen(): void
Protected
Dispatch open event

Returns void
Inherited from BaseEventSource.signalOpen
- Defined in src/BaseEventSource.ts:133

Class EventSource

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Parameters

url: string

eventSourceInitDict: RequestOptions = {}

Returns Node.EventSource

Properties

Private #eventSourceInitDict

Private #reconnectionTime

Private Optional #request

Private Optional #response

Protected _readyState

onerror

onmessage

onopen

Readonly url

Static Readonly CLOSED

Static Readonly CONNECTING

Static Readonly OPEN

Accessors

readyState

Returns undefined | number

Methods

addEventListener

Parameters

type: string

listener: EventListener | EventListenerObject

Optional options: boolean | AddEventListenerOptions

Returns void

Protected Readonly cleaning

Example

Returns void

close

Returns void

dispatchEvent

Parameters

event: Event

Returns boolean

Protected handleInvalidResponse

Returns void

Protected init

Parameters

url: string

Returns void

Protected initStreamAdaptor

Parameters

stream: TransformParser

onErrorCleanUp: (() => void)

Returns void

Returns void

Protected isValidResponse

Parameters

response: { headers?: IncomingHttpHeaders; statusCode?: number; }

Optional headers?: IncomingHttpHeaders

Optional statusCode?: number

Returns boolean

removeEventListener

Parameters

type: string

listener: EventListener | EventListenerObject

Optional options: boolean | EventListenerOptions

Returns void

Protected signalError

Parameters

error: Error

Returns void

Protected signalEvent

Parameters

_event: IEvent

Returns void

Protected signalMessage

Parameters

_event: IEvent

`Private` #eventSourceInitDict

`Private` #reconnectionTime

`Private` `Optional` #request

`Private` `Optional` #response

`Protected` _readyState

`Readonly` url

`Static` `Readonly` CLOSED

`Static` `Readonly` CONNECTING

`Static` `Readonly` OPEN

`Optional` options: boolean | AddEventListenerOptions

`Protected` `Readonly` cleaning

`Protected` handleInvalidResponse

`Protected` init

`Protected` initStreamAdaptor

`Protected` isValidResponse

response: {
headers?: IncomingHttpHeaders;
statusCode?: number;
}

`Optional` headers?: IncomingHttpHeaders

`Optional` statusCode?: number

`Optional` options: boolean | EventListenerOptions

`Protected` signalError

`Protected` signalEvent

`Protected` signalMessage

`Protected` signalOpen