WebPubSubClient class

WebPubSub istemcisi

Oluşturucular

WebPubSubClient(string, WebPubSubClientOptions)

WebPubSubClient örneği oluşturma

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

WebPubSubClient örneği oluşturma

Yöntemler

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

Bir yukarı akış etkinliğini çağırın ve ilişkili yanıtı bekleyin.

joinGroup(string, JoinGroupOptions)

İstemciyi gruplandırmak için birleştirme

leaveGroup(string, LeaveGroupOptions)

İstemciyi gruptan bırakın

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

Bağlı olay için işleyiciyi kaldırma

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

Bağlantısı kesilmiş olay için işleyiciyi kaldırma

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

Grup iletisi için işleyiciyi kaldırma

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

Gruba yeniden katılma işleyicisi kaldırılamadı

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

Sunucu iletisi için işleyiciyi kaldırma

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

Durdurulan olay için işleyiciyi kaldırma

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

Bağlı olay için işleyici ekleme

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

Bağlantısı kesilmiş olay için işleyici ekleme

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

Grup messag'ları için işleyici ekleme

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

Gruba yeniden katılma işleyicisi eklenemedi

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

Sunucu iletileri için işleyici ekleme

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

Durdurulan olay için işleyici ekleme

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

Gelen grup akışlarına abone olun. Her yeni gözlemlenen akış için geri çağrı bir kez çağrılır.

openGroupStream(string, OpenGroupStreamOptions)

Bir gruba çıkış akışı açın.

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

Sunucuya özel olay gönderin.

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

Gruba ileti gönder.

start(StartOptions)

Hizmete başlamaya başlayın.

stop()

İstemciyi durdurun.

Oluşturucu Ayrıntıları

WebPubSubClient(string, WebPubSubClientOptions)

WebPubSubClient örneği oluşturma

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

Parametreler

clientAccessUrl

string

Bağlanacak uri

options
WebPubSubClientOptions

İstemci seçenekleri

WebPubSubClient(WebPubSubClientCredential, WebPubSubClientOptions)

WebPubSubClient örneği oluşturma

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

Parametreler

credential
WebPubSubClientCredential

Bağlanırken kullanılacak kimlik bilgisi

options
WebPubSubClientOptions

İstemci seçenekleri

Yöntem Ayrıntıları

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

Bir yukarı akış etkinliğini çağırın ve ilişkili yanıtı bekleyin.

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

Parametreler

eventName

string

Olay adı

content

JSONTypes | ArrayBuffer

Yük

dataType
WebPubSubDataType

Yük türü

options
InvokeEventOptions

Seçenekleri çağırma

Döndürülenler

joinGroup(string, JoinGroupOptions)

İstemciyi gruplandırmak için birleştirme

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

Parametreler

groupName

string

Grup adı

options
JoinGroupOptions

Gruba katılma seçenekleri

Döndürülenler

Promise<WebPubSubResult>

leaveGroup(string, LeaveGroupOptions)

İstemciyi gruptan bırakın

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

Parametreler

groupName

string

Grup adı

Döndürülenler

Promise<WebPubSubResult>

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

Bağlı olay için işleyiciyi kaldırma

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

Parametreler

event

"connected"

Olay adı

listener

(e: OnConnectedArgs) => void

İşleyici

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

Bağlantısı kesilmiş olay için işleyiciyi kaldırma

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

Parametreler

event

"disconnected"

Olay adı

listener

(e: OnDisconnectedArgs) => void

İşleyici

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

Grup iletisi için işleyiciyi kaldırma

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

Parametreler

event

"group-message"

Olay adı

listener

(e: OnGroupDataMessageArgs) => void

İşleyici

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

Gruba yeniden katılma işleyicisi kaldırılamadı

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

Parametreler

event

"rejoin-group-failed"

Olay adı

listener

(e: OnRejoinGroupFailedArgs) => void

İşleyici

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

Sunucu iletisi için işleyiciyi kaldırma

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

Parametreler

event

"server-message"

Olay adı

listener

(e: OnServerDataMessageArgs) => void

İşleyici

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

Durdurulan olay için işleyiciyi kaldırma

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

Parametreler

event

"stopped"

Olay adı

listener

(e: OnStoppedArgs) => void

İşleyici

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

Bağlı olay için işleyici ekleme

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

Parametreler

event

"connected"

Olay adı

listener

(e: OnConnectedArgs) => void

İşleyici

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

Bağlantısı kesilmiş olay için işleyici ekleme

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

Parametreler

event

"disconnected"

Olay adı

listener

(e: OnDisconnectedArgs) => void

İşleyici

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

Grup messag'ları için işleyici ekleme

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

Parametreler

event

"group-message"

Olay adı

listener

(e: OnGroupDataMessageArgs) => void

İşleyici

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

Gruba yeniden katılma işleyicisi eklenemedi

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

Parametreler

event

"rejoin-group-failed"

Olay adı

listener

(e: OnRejoinGroupFailedArgs) => void

İşleyici

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

Sunucu iletileri için işleyici ekleme

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

Parametreler

event

"server-message"

Olay adı

listener

(e: OnServerDataMessageArgs) => void

İşleyici

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

Durdurulan olay için işleyici ekleme

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

Parametreler

event

"stopped"

Olay adı

listener

(e: OnStoppedArgs) => void

İşleyici

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

Gelen grup akışlarına abone olun. Her yeni gözlemlenen akış için geri çağrı bir kez çağrılır.

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

Parametreler

callback

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

Her gelen akışta geri çağrı çağrılıyordu.

options
OnGroupStreamOptions

Abonelik başına seçenekler, yayınların nasıl takip edileceğini kontrol ediyor.

Döndürülenler

openGroupStream(string, OpenGroupStreamOptions)

Bir gruba çıkış akışı açın.

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

Parametreler

groupName

string

Hedef grup adı.

options
OpenGroupStreamOptions

Açık seçenekleri yayınlayın.

Döndürülenler

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

Sunucuya özel olay gönderin.

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

Parametreler

eventName

string

Olay adı

content

JSONTypes | ArrayBuffer

Veri içeriği

dataType
WebPubSubDataType

Veri türü

options
SendEventOptions

Seçenekler

Döndürülenler

Promise<WebPubSubResult>

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

Gruba ileti gönder.

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

Parametreler

groupName

string

Grup adı

content

JSONTypes | ArrayBuffer

Veri içeriği

dataType
WebPubSubDataType

Veri türü

options
SendToGroupOptions

Seçenekler

Döndürülenler

Promise<WebPubSubResult>

start(StartOptions)

Hizmete başlamaya başlayın.

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

Parametreler

options
StartOptions

Döndürülenler

Promise<void>

stop()

İstemciyi durdurun.

function stop()