WebPubSubClient class
Client WebPubSub
Costruttori
| Web |
Creare un'istanza di WebPubSubClient |
| Web |
Creare un'istanza di WebPubSubClient |
Metodi
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
Promise<InvokeEventResult>
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
- options
- LeaveGroupOptions
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
Promise<GroupStreamWriter>
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()