WebPubSubClient class

Client WebPubSub

Costruttori

WebPubSubClient(string, WebPubSubClientOptions)

Creare un'istanza di WebPubSubClient

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Creare un'istanza di WebPubSubClient

Metodi

invokeEvent(string, JSONTypes | ArrayBuffer, WebPubSubDataType, InvokeEventOptions)

Invoca un evento a monte e attendi la risposta correlata.

joinGroup(string, JoinGroupOptions)

Aggiungere il client a un gruppo

leaveGroup(string, LeaveGroupOptions)

Lasciare il client dal gruppo

off("connected", (e: OnConnectedArgs) => void)

Rimuovere il gestore per l'evento connesso

off("disconnected", (e: OnDisconnectedArgs) => void)

Rimuovere il gestore per l'evento disconnesso

off("group-message", (e: OnGroupDataMessageArgs) => void)

Rimuovere il gestore per il messaggio di gruppo

off("rejoin-group-failed", (e: OnRejoinGroupFailedArgs) => void)

Rimozione del gestore per la ricongiuzione del gruppo non riuscita

off("server-message", (e: OnServerDataMessageArgs) => void)

Rimuovere il gestore per il messaggio del server

off("stopped", (e: OnStoppedArgs) => void)

Rimuovere il gestore per l'evento arrestato

on("connected", (e: OnConnectedArgs) => void)

Aggiungere un gestore per l'evento connesso

on("disconnected", (e: OnDisconnectedArgs) => void)

Aggiungere un gestore per l'evento disconnesso

on("group-message", (e: OnGroupDataMessageArgs) => void)

Aggiungere il gestore per i gruppi messags

on("rejoin-group-failed", (e: OnRejoinGroupFailedArgs) => void)

Impossibile aggiungere il gestore per la ricongiuzione del gruppo

on("server-message", (e: OnServerDataMessageArgs) => void)

Aggiungere un gestore per i messaggi del server

on("stopped", (e: OnStoppedArgs) => void)

Aggiungere un gestore per l'evento arrestato

onGroupStream((stream: GroupStream) => void | Promise<void>, OnGroupStreamOptions)

Iscriviti agli stream di gruppo in entrata. Il callback viene invocato una volta per ogni flusso appena osservato.

openGroupStream(string, OpenGroupStreamOptions)

Apri un flusso in uscita verso un gruppo.

sendEvent(string, JSONTypes | ArrayBuffer, WebPubSubDataType, SendEventOptions)

Inviare un evento personalizzato al server.

sendToGroup(string, JSONTypes | ArrayBuffer, WebPubSubDataType, SendToGroupOptions)

Invia messaggio al gruppo.

start(StartOptions)

Iniziare a avviare il servizio.

stop()

Arrestare il client.

Dettagli costruttore

WebPubSubClient(string, WebPubSubClientOptions)

Creare un'istanza di WebPubSubClient

new WebPubSubClient(clientAccessUrl: string, options?: WebPubSubClientOptions)

Parametri

clientAccessUrl

string

URI da connettere

options
WebPubSubClientOptions

Opzioni client

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Creare un'istanza di WebPubSubClient

new WebPubSubClient(credential: WebPubSubClientCredential, options?: WebPubSubClientOptions)

Parametri

credential
WebPubSubClientCredential

Credenziali da usare per la connessione

options
WebPubSubClientOptions

Opzioni client

Dettagli metodo

invokeEvent(string, JSONTypes | ArrayBuffer, WebPubSubDataType, InvokeEventOptions)

Invoca un evento a monte e attendi la risposta correlata.

function invokeEvent(eventName: string, content: JSONTypes | ArrayBuffer, dataType: WebPubSubDataType, options?: InvokeEventOptions): Promise<InvokeEventResult>

Parametri

eventName

string

Nome dell'evento

content

JSONTypes | ArrayBuffer

Il carico utile

dataType
WebPubSubDataType

Tipo di payload

options
InvokeEventOptions

Opzioni di invocazione

Valori restituiti

joinGroup(string, JoinGroupOptions)

Aggiungere il client a un gruppo

function joinGroup(groupName: string, options?: JoinGroupOptions): Promise<WebPubSubResult>

Parametri

groupName

string

Nome del gruppo

options
JoinGroupOptions

Opzioni del gruppo di join

Valori restituiti

Promise<WebPubSubResult>

leaveGroup(string, LeaveGroupOptions)

Lasciare il client dal gruppo

function leaveGroup(groupName: string, options?: LeaveGroupOptions): Promise<WebPubSubResult>

Parametri

groupName

string

Nome del gruppo

Valori restituiti

Promise<WebPubSubResult>

off("connected", (e: OnConnectedArgs) => void)

Rimuovere il gestore per l'evento connesso

function off(event: "connected", listener: (e: OnConnectedArgs) => void)

Parametri

event

"connected"

Nome dell'evento

listener

(e: OnConnectedArgs) => void

Gestore

off("disconnected", (e: OnDisconnectedArgs) => void)

Rimuovere il gestore per l'evento disconnesso

function off(event: "disconnected", listener: (e: OnDisconnectedArgs) => void)

Parametri

event

"disconnected"

Nome dell'evento

listener

(e: OnDisconnectedArgs) => void

Gestore

off("group-message", (e: OnGroupDataMessageArgs) => void)

Rimuovere il gestore per il messaggio di gruppo

function off(event: "group-message", listener: (e: OnGroupDataMessageArgs) => void)

Parametri

event

"group-message"

Nome dell'evento

listener

(e: OnGroupDataMessageArgs) => void

Gestore

off("rejoin-group-failed", (e: OnRejoinGroupFailedArgs) => void)

Rimozione del gestore per la ricongiuzione del gruppo non riuscita

function off(event: "rejoin-group-failed", listener: (e: OnRejoinGroupFailedArgs) => void)

Parametri

event

"rejoin-group-failed"

Nome dell'evento

listener

(e: OnRejoinGroupFailedArgs) => void

Gestore

off("server-message", (e: OnServerDataMessageArgs) => void)

Rimuovere il gestore per il messaggio del server

function off(event: "server-message", listener: (e: OnServerDataMessageArgs) => void)

Parametri

event

"server-message"

Nome dell'evento

listener

(e: OnServerDataMessageArgs) => void

Gestore

off("stopped", (e: OnStoppedArgs) => void)

Rimuovere il gestore per l'evento arrestato

function off(event: "stopped", listener: (e: OnStoppedArgs) => void)

Parametri

event

"stopped"

Nome dell'evento

listener

(e: OnStoppedArgs) => void

Gestore

on("connected", (e: OnConnectedArgs) => void)

Aggiungere un gestore per l'evento connesso

function on(event: "connected", listener: (e: OnConnectedArgs) => void)

Parametri

event

"connected"

Nome dell'evento

listener

(e: OnConnectedArgs) => void

Gestore

on("disconnected", (e: OnDisconnectedArgs) => void)

Aggiungere un gestore per l'evento disconnesso

function on(event: "disconnected", listener: (e: OnDisconnectedArgs) => void)

Parametri

event

"disconnected"

Nome dell'evento

listener

(e: OnDisconnectedArgs) => void

Gestore

on("group-message", (e: OnGroupDataMessageArgs) => void)

Aggiungere il gestore per i gruppi messags

function on(event: "group-message", listener: (e: OnGroupDataMessageArgs) => void)

Parametri

event

"group-message"

Nome dell'evento

listener

(e: OnGroupDataMessageArgs) => void

Gestore

on("rejoin-group-failed", (e: OnRejoinGroupFailedArgs) => void)

Impossibile aggiungere il gestore per la ricongiuzione del gruppo

function on(event: "rejoin-group-failed", listener: (e: OnRejoinGroupFailedArgs) => void)

Parametri

event

"rejoin-group-failed"

Nome dell'evento

listener

(e: OnRejoinGroupFailedArgs) => void

Gestore

on("server-message", (e: OnServerDataMessageArgs) => void)

Aggiungere un gestore per i messaggi del server

function on(event: "server-message", listener: (e: OnServerDataMessageArgs) => void)

Parametri

event

"server-message"

Nome dell'evento

listener

(e: OnServerDataMessageArgs) => void

Gestore

on("stopped", (e: OnStoppedArgs) => void)

Aggiungere un gestore per l'evento arrestato

function on(event: "stopped", listener: (e: OnStoppedArgs) => void)

Parametri

event

"stopped"

Nome dell'evento

listener

(e: OnStoppedArgs) => void

Gestore

onGroupStream((stream: GroupStream) => void | Promise<void>, OnGroupStreamOptions)

Iscriviti agli stream di gruppo in entrata. Il callback viene invocato una volta per ogni flusso appena osservato.

function onGroupStream(callback: (stream: GroupStream) => void | Promise<void>, options?: OnGroupStreamOptions): GroupStreamSubscription

Parametri

callback

(stream: GroupStream) => void | Promise<void>

Richiamo invocato ad ogni stream in arrivo.

options
OnGroupStreamOptions

Opzioni per abbonamento che controllano come vengono tracciati gli stream.

Valori restituiti

openGroupStream(string, OpenGroupStreamOptions)

Apri un flusso in uscita verso un gruppo.

function openGroupStream(groupName: string, options?: OpenGroupStreamOptions): Promise<GroupStreamWriter>

Parametri

groupName

string

Nome del gruppo bersaglio.

options
OpenGroupStreamOptions

Opzioni aperte per streaming.

Valori restituiti

sendEvent(string, JSONTypes | ArrayBuffer, WebPubSubDataType, SendEventOptions)

Inviare un evento personalizzato al server.

function sendEvent(eventName: string, content: JSONTypes | ArrayBuffer, dataType: WebPubSubDataType, options?: SendEventOptions): Promise<WebPubSubResult>

Parametri

eventName

string

Nome dell'evento

content

JSONTypes | ArrayBuffer

Contenuto dei dati

dataType
WebPubSubDataType

Tipo di dati

options
SendEventOptions

Opzioni

Valori restituiti

Promise<WebPubSubResult>

sendToGroup(string, JSONTypes | ArrayBuffer, WebPubSubDataType, SendToGroupOptions)

Invia messaggio al gruppo.

function sendToGroup(groupName: string, content: JSONTypes | ArrayBuffer, dataType: WebPubSubDataType, options?: SendToGroupOptions): Promise<WebPubSubResult>

Parametri

groupName

string

Nome del gruppo

content

JSONTypes | ArrayBuffer

Contenuto dei dati

dataType
WebPubSubDataType

Tipo di dati

options
SendToGroupOptions

Opzioni

Valori restituiti

Promise<WebPubSubResult>

start(StartOptions)

Iniziare a avviare il servizio.

function start(options?: StartOptions): Promise<void>

Parametri

options
StartOptions

Valori restituiti

Promise<void>

stop()

Arrestare il client.

function stop()