GroupStreamWriter interface

Abstraction du groupe de streams writer pour envoyer un flux logique à un groupe.

Propriétés

streamId

Identifiant du flux.

Méthodes

abort(StreamEndError, AbortGroupStreamOptions)

Interrompez le flux avec une erreur.

end(EndGroupStreamOptions)

Terminez le stream avec succès.

onError((error: StreamDataError) => void)

Erreur de rappel du flux sortant du registre. Renvoie une fonction pour désenregistrer ce rappel.

write(JSONTypes | ArrayBuffer, WebPubSubDataType, GroupStreamWriteOptions)

Écris un fragment de flux.

Détails de la propriété

streamId

Identifiant du flux.

streamId: string

Valeur de propriété

string

Détails de la méthode

abort(StreamEndError, AbortGroupStreamOptions)

Interrompez le flux avec une erreur.

function abort(error: StreamEndError, options?: AbortGroupStreamOptions): Promise<void>

Paramètres

Retours

Promise<void>

end(EndGroupStreamOptions)

Terminez le stream avec succès.

function end(options?: EndGroupStreamOptions): Promise<void>

Paramètres

Retours

Promise<void>

onError((error: StreamDataError) => void)

Erreur de rappel du flux sortant du registre. Renvoie une fonction pour désenregistrer ce rappel.

function onError(listener: (error: StreamDataError) => void): () => void

Paramètres

listener

(error: StreamDataError) => void

Retours

() => void

write(JSONTypes | ArrayBuffer, WebPubSubDataType, GroupStreamWriteOptions)

Écris un fragment de flux.

function write(content: JSONTypes | ArrayBuffer, dataType: WebPubSubDataType, options?: GroupStreamWriteOptions): Promise<void>

Paramètres

content

JSONTypes | ArrayBuffer

Retours

Promise<void>