WebPubSubClient class

Der WebPubSub-Client

Konstruktoren

WebPubSubClient(string, WebPubSubClientOptions)

Erstellen einer Instanz von WebPubSubClient

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Erstellen einer Instanz von WebPubSubClient

Methoden

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

Rufen Sie ein Upstream-Ereignis aus und warten Sie auf die korrelierte Antwort.

joinGroup(string, JoinGroupOptions)

Beitreten zum Client zur Gruppe

leaveGroup(string, LeaveGroupOptions)

Verlassen des Clients aus der Gruppe

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

Entfernen des Handlers für verbundene Ereignisse

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

Entfernen des Handlers für das getrennte Ereignis

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

Entfernen des Handlers für Gruppennachrichten

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

Fehler beim Entfernen des Handlers für die erneute Teilnahme an der Gruppe.

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

Entfernen des Handlers für Servernachrichten

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

Entfernen des Handlers für das beendete Ereignis

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

Hinzufügen eines Handlers für verbundene Ereignisse

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

Hinzufügen eines Handlers für getrenntes Ereignis

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

Hinzufügen eines Handlers für Gruppen-Messags

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

Fehler beim Hinzufügen des Handlers für die erneute Teilnahme an der Gruppe.

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

Hinzufügen eines Handlers für Servernachrichten

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

Hinzufügen eines Handlers für das beendete Ereignis

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

Abonnieren Sie eingehende Gruppenstreams. Der Rückruf wird einmal für jeden neu beobachteten Stream aufgerufen.

openGroupStream(string, OpenGroupStreamOptions)

Öffne einen ausgehenden Stream für eine Gruppe.

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

Benutzerdefiniertes Ereignis an den Server senden.

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

Nachricht an Gruppe senden.

start(StartOptions)

Beginnen Sie, um mit dem Dienst zu beginnen.

stop()

Beenden Sie den Client.

Details zum Konstruktor

WebPubSubClient(string, WebPubSubClientOptions)

Erstellen einer Instanz von WebPubSubClient

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

Parameter

clientAccessUrl

string

Der zu verbindende URI

options
WebPubSubClientOptions

Die Clientoptionen

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Erstellen einer Instanz von WebPubSubClient

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

Parameter

credential
WebPubSubClientCredential

Die beim Herstellen einer Verbindung zu verwendenden Anmeldeinformationen

options
WebPubSubClientOptions

Die Clientoptionen

Details zur Methode

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

Rufen Sie ein Upstream-Ereignis aus und warten Sie auf die korrelierte Antwort.

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

Parameter

eventName

string

Der Ereignisname

content

JSONTypes | ArrayBuffer

Die Nutzlast

dataType
WebPubSubDataType

Der Nutzlasttyp

options
InvokeEventOptions

Optionen aufrufen

Gibt zurück

joinGroup(string, JoinGroupOptions)

Beitreten zum Client zur Gruppe

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

Parameter

groupName

string

Der Gruppenname

options
JoinGroupOptions

Die Optionen für die Verknüpfungsgruppe

Gibt zurück

Promise<WebPubSubResult>

leaveGroup(string, LeaveGroupOptions)

Verlassen des Clients aus der Gruppe

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

Parameter

groupName

string

Der Gruppenname

Gibt zurück

Promise<WebPubSubResult>

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

Entfernen des Handlers für verbundene Ereignisse

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

Parameter

event

"connected"

Der Ereignisname

listener

(e: OnConnectedArgs) => void

Der Handler

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

Entfernen des Handlers für das getrennte Ereignis

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

Parameter

event

"disconnected"

Der Ereignisname

listener

(e: OnDisconnectedArgs) => void

Der Handler

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

Entfernen des Handlers für Gruppennachrichten

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

Parameter

event

"group-message"

Der Ereignisname

listener

(e: OnGroupDataMessageArgs) => void

Der Handler

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

Fehler beim Entfernen des Handlers für die erneute Teilnahme an der Gruppe.

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

Parameter

event

"rejoin-group-failed"

Der Ereignisname

listener

(e: OnRejoinGroupFailedArgs) => void

Der Handler

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

Entfernen des Handlers für Servernachrichten

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

Parameter

event

"server-message"

Der Ereignisname

listener

(e: OnServerDataMessageArgs) => void

Der Handler

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

Entfernen des Handlers für das beendete Ereignis

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

Parameter

event

"stopped"

Der Ereignisname

listener

(e: OnStoppedArgs) => void

Der Handler

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

Hinzufügen eines Handlers für verbundene Ereignisse

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

Parameter

event

"connected"

Der Ereignisname

listener

(e: OnConnectedArgs) => void

Der Handler

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

Hinzufügen eines Handlers für getrenntes Ereignis

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

Parameter

event

"disconnected"

Der Ereignisname

listener

(e: OnDisconnectedArgs) => void

Der Handler

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

Hinzufügen eines Handlers für Gruppen-Messags

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

Parameter

event

"group-message"

Der Ereignisname

listener

(e: OnGroupDataMessageArgs) => void

Der Handler

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

Fehler beim Hinzufügen des Handlers für die erneute Teilnahme an der Gruppe.

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

Parameter

event

"rejoin-group-failed"

Der Ereignisname

listener

(e: OnRejoinGroupFailedArgs) => void

Der Handler

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

Hinzufügen eines Handlers für Servernachrichten

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

Parameter

event

"server-message"

Der Ereignisname

listener

(e: OnServerDataMessageArgs) => void

Der Handler

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

Hinzufügen eines Handlers für das beendete Ereignis

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

Parameter

event

"stopped"

Der Ereignisname

listener

(e: OnStoppedArgs) => void

Der Handler

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

Abonnieren Sie eingehende Gruppenstreams. Der Rückruf wird einmal für jeden neu beobachteten Stream aufgerufen.

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

Parameter

callback

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

Callback wird mit jedem eingehenden Strom aufgerufen.

options
OnGroupStreamOptions

Optionen pro Abonnement, die steuern, wie Streams verfolgt werden.

Gibt zurück

openGroupStream(string, OpenGroupStreamOptions)

Öffne einen ausgehenden Stream für eine Gruppe.

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

Parameter

groupName

string

Name der Zielgruppe.

options
OpenGroupStreamOptions

Streame, öffne Optionen.

Gibt zurück

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

Benutzerdefiniertes Ereignis an den Server senden.

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

Parameter

eventName

string

Der Ereignisname

content

JSONTypes | ArrayBuffer

Der Dateninhalt

dataType
WebPubSubDataType

Der Datentyp

options
SendEventOptions

Die Optionen

Gibt zurück

Promise<WebPubSubResult>

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

Nachricht an Gruppe senden.

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

Parameter

groupName

string

Der Gruppenname

content

JSONTypes | ArrayBuffer

Der Dateninhalt

dataType
WebPubSubDataType

Der Datentyp

options
SendToGroupOptions

Die Optionen

Gibt zurück

Promise<WebPubSubResult>

start(StartOptions)

Beginnen Sie, um mit dem Dienst zu beginnen.

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

Parameter

options
StartOptions

Gibt zurück

Promise<void>

stop()

Beenden Sie den Client.

function stop()