@terascope/teraslice-messaging / messenger/client / Client

Class: Client

Defined in: messenger/client.ts:14

Extends

• Core

Extended by

• Client
• Client

Constructors

new Client()

new Client(opts, _connectTimeout?): Client

Defined in: messenger/client.ts:25

Parameters

Parameter	Type
opts	ClientOptions
_connectTimeout?	number

Returns

Client

Overrides

Core.constructor

Properties

Property	Modifier	Type	Default value	Inherited from	Defined in
actionTimeout	protected	number	undefined	Core.actionTimeout	messenger/core.ts:16
available	public	boolean	undefined	-	messenger/client.ts:21
clientId	readonly	string	undefined	-	messenger/client.ts:16
clientType	readonly	string	undefined	-	messenger/client.ts:17
closed	public	boolean	false	Core.closed	messenger/core.ts:13
connectTimeout	readonly	number	undefined	-	messenger/client.ts:19
hostUrl	readonly	string	undefined	-	messenger/client.ts:20
logger	protected	Logger	undefined	Core.logger	messenger/core.ts:17
networkLatencyBuffer	protected	number	undefined	Core.networkLatencyBuffer	messenger/core.ts:15
ready	public	boolean	undefined	-	messenger/client.ts:22
serverName	readonly	string	undefined	-	messenger/client.ts:18
serverShutdown	protected	boolean	undefined	-	messenger/client.ts:23
socket	readonly	Socket	undefined	-	messenger/client.ts:15

Methods

close()

close(): void

Defined in: messenger/core.ts:39

Returns

void

Inherited from

Core.close

---

connect()

connect(): Promise<void>

Defined in: messenger/client.ts:113

Returns

Promise<void>

---

emit()

emit(eventName, msg): void

Defined in: messenger/client.ts:286

Synchronously calls each of the listeners registered for the event named eventName, in the order they were registered, passing the supplied arguments to each.

Returns true if the event had listeners, false otherwise.

import { EventEmitter } from 'node:events';
const myEmitter = new EventEmitter();

// First listener
myEmitter.on('event', function firstListener() {
  console.log('Helloooo! first listener');
});
// Second listener
myEmitter.on('event', function secondListener(arg1, arg2) {
  console.log(`event with parameters ${arg1}, ${arg2} in second listener`);
});
// Third listener
myEmitter.on('event', function thirdListener(...args) {
  const parameters = args.join(', ');
  console.log(`event with parameters ${parameters} in third listener`);
});

console.log(myEmitter.listeners('event'));

myEmitter.emit('event', 1, 2, 3, 4, 5);

// Prints:
// [
//   [Function: firstListener],
//   [Function: secondListener],
//   [Function: thirdListener]
// ]
// Helloooo! first listener
// event with parameters 1, 2 in second listener
// event with parameters 1, 2, 3, 4, 5 in third listener

Parameters

Parameter	Type
eventName	string
msg	ClientEventMessage

Returns

void

Since

v0.1.26

Overrides

Core.emit

---

forceReconnect()

forceReconnect(): Promise<void>

Defined in: messenger/client.ts:322

Returns

Promise<void>

---

getTimeout()

getTimeout(timeout?): number

Defined in: messenger/core.ts:156

Parameters

Parameter	Type
timeout?	number

Returns

number

Inherited from

Core.getTimeout

---

getTimeoutWithMax()

getTimeoutWithMax(maxTimeout): number

Defined in: messenger/core.ts:151

Parameters

Parameter	Type
maxTimeout	number

Returns

number

Inherited from

Core.getTimeoutWithMax

---

handleResponse()

protected handleResponse(socket, eventName, fn): void

Defined in: messenger/core.ts:93

Parameters

Parameter	Type
socket	SocketEmitter
eventName	string
fn	MessageHandler

Returns

void

Inherited from

Core.handleResponse

---

handleSendResponse()

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

Defined in: messenger/core.ts:44

Parameters

Parameter	Type	Default value
sent	Message	undefined
sendAbortSignal	boolean	false

Returns

Promise<null | Message>

Inherited from

Core.handleSendResponse

---

isClientReady()

isClientReady(): boolean

Defined in: messenger/client.ts:291

Returns

boolean

Overrides

Core.isClientReady

---

onceWithTimeout()

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

Defined in: messenger/core.ts:168

Parameters

Parameter	Type
eventName	string
timeout?	number
abortSignal?	AbortSignal

Returns

Promise<any>

Inherited from

Core.onceWithTimeout

---

onServerShutdown()

onServerShutdown(fn): void

Defined in: messenger/client.ts:99

Parameters

Parameter	Type
fn	() => void

Returns

void

---

send()

protected send(eventName, payload, options): Promise<null | Message>

Defined in: messenger/client.ts:254

Parameters

Parameter	Type
eventName	string
payload	Payload
options	SendOptions

Returns

Promise<null | Message>

---

sendAvailable()

sendAvailable(payload?): Promise<undefined | null | Message>

Defined in: messenger/client.ts:236

Parameters

Parameter	Type
payload?	Payload

Returns

Promise<undefined | null | Message>

---

sendUnavailable()

sendUnavailable(payload?): Promise<undefined | null | Message>

Defined in: messenger/client.ts:245

Parameters

Parameter	Type
payload?	Payload

Returns

Promise<undefined | null | Message>

---

shutdown()

shutdown(): Promise<void>

Defined in: messenger/client.ts:295

Returns

Promise<void>

---

waitForClientReady()

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

Defined in: messenger/core.ts:137

Parameters

Parameter	Type
clientId	string
timeout?	number

Returns

Promise<boolean>

Inherited from

Core.waitForClientReady