import StreamMessage from 'foglet-core/src/network/communication/stream/stream-message.js'

public class | source

StreamMessage

Extends:

* → StreamMessage

A StreamMessage enable to receive data streamed using a StreamRequest.

Example:

const foglet = getSomeFoglet();
foglet.onStreamUnicast((id, stream) => {
 console.log('a peer with id = ', id, ' is streaming data to me');
 stream.on('data', data => console.log(data));
 stream.on('end', () => console.log('no more data available from the stream'));
});

Constructor Summary

Public Constructor
public	constructor() Constructor

Member Summary

Public Members
public get	trailers: Array: * Get the trailing data of the message.

Private Members
private	_trailers: *

Public Constructors

public constructor() source

Constructor

Public Members

public get trailers: Array: * source

Get the trailing data of the message. Only populated once the end event has been fired.