@terascope/teraslice-messaging / messenger/core / Core

Class: Core

Extends

• EventEmitter

Extended by

• Client
• Server

Constructors

new Core()

new Core(opts): Core

Parameters

Parameter	Type
opts	CoreOptions

Returns

Core

Overrides

EventEmitter.constructor

Source

messenger/core.ts:19

Properties

actionTimeout

protected actionTimeout: number

Source

messenger/core.ts:16

---

closed

closed: boolean = false

Source

messenger/core.ts:13

---

logger

protected logger: Logger

Source

messenger/core.ts:17

---

networkLatencyBuffer

protected networkLatencyBuffer: number

Source

messenger/core.ts:15

Methods

close()

close(): void

Returns

void

Source

messenger/core.ts:39

---

emit()

emit(eventName, msg): void

Parameters

Parameter	Type
eventName	string
msg	EventMessage

Returns

void

Overrides

EventEmitter.emit

Source

messenger/core.ts:144

---

getTimeout()

getTimeout(timeout?): number

Parameters

Parameter	Type
timeout?	number

Returns

number

Source

messenger/core.ts:139

---

getTimeoutWithMax()

getTimeoutWithMax(maxTimeout): number

Parameters

Parameter	Type
maxTimeout	number

Returns

number

Source

messenger/core.ts:134

---

handleResponse()

protected handleResponse(socket, eventName, fn): void

Parameters

Parameter	Type
socket	SocketEmitter
eventName	string
fn	MessageHandler

Returns

void

Source

messenger/core.ts:76

---

handleSendResponse()

protected handleSendResponse(sent, signal?): Promise<null | Message>

Parameters

Parameter	Type
sent	Message
signal?	AbortSignal

Returns

Promise<null | Message>

Source

messenger/core.ts:44

---

isClientReady()

isClientReady(clientId?): boolean

Parameters

Parameter	Type
clientId?	string

Returns

boolean

Source

messenger/core.ts:115

---

onceWithTimeout()

onceWithTimeout(eventName, timeout?, abortSignal?): Promise<any>

Parameters

Parameter	Type
eventName	string
timeout?	number
abortSignal?	AbortSignal

Returns

Promise<any>

Source

messenger/core.ts:151

---

waitForClientReady()

waitForClientReady(clientId, timeout?): Promise<boolean>

Parameters

Parameter	Type
clientId	string
timeout?	number

Returns

Promise<boolean>

Source

messenger/core.ts:120