Compartir a través de


PayloadReceiver class

Receptor de carga para streaming.

Propiedades

disconnected
isConnected

Obtención del estado conectado actual

Métodos

connect(ITransportReceiver)

Se conecta a un receptor de transporte

disconnect(TransportDisconnectedEvent)

Forzar que este receptor se desconecte.

subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)

Permite suscribirse a este receptor para recibir notificaciones cuando entran nuevos datos.

Detalles de las propiedades

disconnected

disconnected?: TransportDisconnectedEventHandler

Valor de propiedad

isConnected

Obtención del estado conectado actual

boolean isConnected

Valor de propiedad

boolean

true si está conectado a un remitente de transporte.

Detalles del método

connect(ITransportReceiver)

Se conecta a un receptor de transporte

function connect(receiver: ITransportReceiver): Promise<void>

Parámetros

receiver
ITransportReceiver

Objeto ITransportReceiver para extraer los datos entrantes.

Devoluciones

Promise<void>

una promesa que se resuelve cuando se completa el receptor

disconnect(TransportDisconnectedEvent)

Forzar que este receptor se desconecte.

function disconnect(event?: TransportDisconnectedEvent)

Parámetros

event
TransportDisconnectedEvent

Argumentos de evento que se van a incluir al difundir el evento de desconexión.

subscribe((header: IHeader) => SubscribableStream, (header: IHeader, stream: SubscribableStream, count: number) => void)

Permite suscribirse a este receptor para recibir notificaciones cuando entran nuevos datos.

function subscribe(getStream: (header: IHeader) => SubscribableStream, receiveAction: (header: IHeader, stream: SubscribableStream, count: number) => void)

Parámetros

getStream

(header: IHeader) => SubscribableStream

Devolución de llamada cuando se ha recibido una nueva secuencia.

receiveAction

(header: IHeader, stream: SubscribableStream, count: number) => void

Devolución de llamada cuando se ha recibido un nuevo mensaje.