WebPubSubClient class

El cliente WebPubSub

Constructores

WebPubSubClient(string, WebPubSubClientOptions)

Creación de una instancia de WebPubSubClient

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Creación de una instancia de WebPubSubClient

Métodos

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

Invoca un evento aguas arriba y espera la respuesta correlacionada.

joinGroup(string, JoinGroupOptions)

Unión del cliente al grupo

leaveGroup(string, LeaveGroupOptions)

Dejar el cliente del grupo

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

Eliminación del controlador para el evento conectado

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

Quitar controlador para el evento desconectado

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

Quitar controlador para el mensaje de grupo

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

Error al quitar el controlador para volver a unir el grupo

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

Quitar controlador para el mensaje del servidor

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

Quitar controlador para el evento detenido

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

Adición de un controlador para el evento conectado

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

Agregar controlador para el evento desconectado

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

Agregar controlador para grupos messags

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

Error al agregar el controlador para volver a unir el grupo

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

Agregar controlador para mensajes de servidor

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

Agregar controlador para el evento detenido

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

Suscríbete a los streams de grupos entrantes. La callback se invoca una vez por cada flujo nuevo observado.

openGroupStream(string, OpenGroupStreamOptions)

Abre un flujo saliente a un grupo.

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

Enviar eventos personalizados al servidor.

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

Enviar mensaje al grupo.

start(StartOptions)

Empiece a iniciarse en el servicio.

stop()

Detenga el cliente.

Detalles del constructor

WebPubSubClient(string, WebPubSubClientOptions)

Creación de una instancia de WebPubSubClient

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

Parámetros

clientAccessUrl

string

Identificador URI que se va a conectar

options
WebPubSubClientOptions

Opciones de cliente

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

Creación de una instancia de WebPubSubClient

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

Parámetros

credential
WebPubSubClientCredential

Credencial que se va a usar al conectarse

options
WebPubSubClientOptions

Opciones de cliente

Detalles del método

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

Invoca un evento aguas arriba y espera la respuesta correlacionada.

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

Parámetros

eventName

string

Nombre del evento

content

JSONTypes | ArrayBuffer

La carga útil

dataType
WebPubSubDataType

Tipo de carga útil

options
InvokeEventOptions

Opciones de invocación

Devoluciones

joinGroup(string, JoinGroupOptions)

Unión del cliente al grupo

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

Parámetros

groupName

string

Nombre del grupo

options
JoinGroupOptions

Opciones del grupo de unión

Devoluciones

Promise<WebPubSubResult>

leaveGroup(string, LeaveGroupOptions)

Dejar el cliente del grupo

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

Parámetros

groupName

string

Nombre del grupo

Devoluciones

Promise<WebPubSubResult>

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

Eliminación del controlador para el evento conectado

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

Parámetros

event

"connected"

Nombre del evento

listener

(e: OnConnectedArgs) => void

Controlador

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

Quitar controlador para el evento desconectado

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

Parámetros

event

"disconnected"

Nombre del evento

listener

(e: OnDisconnectedArgs) => void

Controlador

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

Quitar controlador para el mensaje de grupo

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

Parámetros

event

"group-message"

Nombre del evento

listener

(e: OnGroupDataMessageArgs) => void

Controlador

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

Error al quitar el controlador para volver a unir el grupo

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

Parámetros

event

"rejoin-group-failed"

Nombre del evento

listener

(e: OnRejoinGroupFailedArgs) => void

Controlador

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

Quitar controlador para el mensaje del servidor

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

Parámetros

event

"server-message"

Nombre del evento

listener

(e: OnServerDataMessageArgs) => void

Controlador

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

Quitar controlador para el evento detenido

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

Parámetros

event

"stopped"

Nombre del evento

listener

(e: OnStoppedArgs) => void

Controlador

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

Adición de un controlador para el evento conectado

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

Parámetros

event

"connected"

Nombre del evento

listener

(e: OnConnectedArgs) => void

Controlador

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

Agregar controlador para el evento desconectado

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

Parámetros

event

"disconnected"

Nombre del evento

listener

(e: OnDisconnectedArgs) => void

Controlador

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

Agregar controlador para grupos messags

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

Parámetros

event

"group-message"

Nombre del evento

listener

(e: OnGroupDataMessageArgs) => void

Controlador

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

Error al agregar el controlador para volver a unir el grupo

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

Parámetros

event

"rejoin-group-failed"

Nombre del evento

listener

(e: OnRejoinGroupFailedArgs) => void

Controlador

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

Agregar controlador para mensajes de servidor

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

Parámetros

event

"server-message"

Nombre del evento

listener

(e: OnServerDataMessageArgs) => void

Controlador

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

Agregar controlador para el evento detenido

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

Parámetros

event

"stopped"

Nombre del evento

listener

(e: OnStoppedArgs) => void

Controlador

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

Suscríbete a los streams de grupos entrantes. La callback se invoca una vez por cada flujo nuevo observado.

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

Parámetros

callback

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

Se invoca la llamada de regreso con cada stream entrante.

options
OnGroupStreamOptions

Opciones por suscripción que controlan cómo se rastrean las retransmisiones.

Devoluciones

openGroupStream(string, OpenGroupStreamOptions)

Abre un flujo saliente a un grupo.

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

Parámetros

groupName

string

Nombre del grupo objetivo.

options
OpenGroupStreamOptions

Opciones abiertas de streaming.

Devoluciones

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

Enviar eventos personalizados al servidor.

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

Parámetros

eventName

string

Nombre del evento

content

JSONTypes | ArrayBuffer

El contenido de los datos

dataType
WebPubSubDataType

El tipo de datos

options
SendEventOptions

Las opciones

Devoluciones

Promise<WebPubSubResult>

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

Enviar mensaje al grupo.

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

Parámetros

groupName

string

Nombre del grupo

content

JSONTypes | ArrayBuffer

El contenido de los datos

dataType
WebPubSubDataType

El tipo de datos

options
SendToGroupOptions

Las opciones

Devoluciones

Promise<WebPubSubResult>

start(StartOptions)

Empiece a iniciarse en el servicio.

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

Parámetros

options
StartOptions

Devoluciones

Promise<void>

stop()

Detenga el cliente.

function stop()