StreamManager class
Organiza y administra secuencias.
Constructores
Stream |
Inicializa una nueva instancia de la clase |
Métodos
close |
Cierra el |
get |
Recupera un PayloadAssembler con el identificador especificado si existe, de lo contrario, se crea una nueva instancia y se le asigna el identificador especificado. |
get |
Recupera el |
on |
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
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
function closeStream(id: string)
Parámetros
- id
-
string
Identificador del de
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
function getPayloadStream(header: IHeader): SubscribableStream
Parámetros
- header
- IHeader
Encabezado del de
Devoluciones
El
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.