Skip to content

Documentation / @imvu/client / RealtimeCoordinator

Class: RealtimeCoordinator ​

Defined in: packages/client/src/client/RealtimeCoordinator.ts:48

Bridges REST update targets to reference-counted IMQ invalidations and raw mount subscriptions.

Constructors ​

Constructor ​

ts
new RealtimeCoordinator(client, createManager?): RealtimeCoordinator;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:55

Parameters ​

ParameterType
clientClient
createManager?RealtimeManagerFactory

Returns ​

RealtimeCoordinator

Methods ​

close() ​

ts
close(): void;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:116

Returns ​

void


listen() ​

ts
listen(
   queue, 
   mount, 
   listener
): Promise<RealtimeSubscription>;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:79

Subscribe to every message on a mount, sharing the IMQ subscription with any watches of the same target. Connects IMQ on first use.

Parameters ​

ParameterType
queuestring
mountstring
listenerMessageListener

Returns ​

Promise<RealtimeSubscription>


onReconnect() ​

ts
onReconnect(listener): () => void;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:111

Run listener after each IMQ reconnect (not the first connect). Subscriptions are restored automatically, but anything delivered while disconnected was missed, so this is the cue to resynchronize from REST. Returns an unsubscribe function.

Parameters ​

ParameterType
listener() => void

Returns ​

() => void


send() ​

ts
send(
   queue, 
   mount, 
   message
): Promise<void>;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:96

Send a message on a mount; resolves once the gateway acknowledges it.

Parameters ​

ParameterType
queuestring
mountstring
messageunknown

Returns ​

Promise<void>


watch() ​

ts
watch<T>(document): Promise<DocumentWatch<T>>;

Defined in: packages/client/src/client/RealtimeCoordinator.ts:60

Type Parameters ​

Type Parameter
T extends RemoteDocument

Parameters ​

ParameterType
documentT

Returns ​

Promise<DocumentWatch<T>>

Released under the MIT License.