Compartir a través de


StreamManager class

Organiza y administra secuencias.

Constructores

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Inicializa una nueva instancia de la clase StreamManager.

Métodos

closeStream(string)

Cierra el PayloadAssembler asignado al de SubscribableStream con el identificador especificado.

getPayloadAssembler(string)

Recupera un PayloadAssembler con el identificador especificado si existe, de lo contrario, se crea una nueva instancia y se le asigna el identificador especificado.

getPayloadStream(IHeader)

Recupera el SubscribableStream del PayloadAssembler administra este administrador.

onReceive(IHeader, SubscribableStream, number)

Se usa para establecer el comportamiento del payloadAssembler administrado cuando se reciben los datos.

Detalles del constructor

StreamManager((contentStreamAssembler: PayloadAssembler) => void)

Inicializa una nueva instancia de la clase StreamManager.

new StreamManager(onCancelStream: (contentStreamAssembler: PayloadAssembler) => void)

Parámetros

onCancelStream

(contentStreamAssembler: PayloadAssembler) => void

Función que se desencadenará si se cancela la secuencia administrada.

Detalles del método

closeStream(string)

Cierra el PayloadAssembler asignado al de SubscribableStream con el identificador especificado.

function closeStream(id: string)

Parámetros

id

string

Identificador del de SuscripciónStream que se va a cerrar.

getPayloadAssembler(string)

Recupera un PayloadAssembler con el identificador especificado si existe, de lo contrario, se crea una nueva instancia y se le asigna el identificador especificado.

function getPayloadAssembler(id: string): PayloadAssembler

Parámetros

id

string

El identificador del PayloadAssembler recuperar o crear.

Devoluciones

El PayloadAssembler con el identificador especificado.

getPayloadStream(IHeader)

Recupera el SubscribableStream del PayloadAssembler administra este administrador.

function getPayloadStream(header: IHeader): SubscribableStream

Parámetros

header
IHeader

Encabezado del de SubscribableStream que se va a recuperar.

Devoluciones

El SubscribableStream con el encabezado especificado.

onReceive(IHeader, SubscribableStream, number)

Se usa para establecer el comportamiento del payloadAssembler administrado cuando se reciben los datos.

function onReceive(header: IHeader, contentStream: SubscribableStream, contentLength: number)

Parámetros

header
IHeader

Encabezado de la secuencia.

contentStream
SubscribableStream

suscripciónStream para escribir datos entrantes.

contentLength

number

Cantidad de datos que se van a escribir en contentStream.