2021-02-04 19:15:23 +01:00
|
|
|
import ObjectMultiplex from 'obj-multiplex';
|
|
|
|
import pump from 'pump';
|
2016-04-08 23:24:10 +02:00
|
|
|
|
2018-04-16 17:29:43 +02:00
|
|
|
/**
|
|
|
|
* Sets up stream multiplexing for the given stream
|
2022-01-07 16:57:33 +01:00
|
|
|
*
|
2018-04-16 17:29:43 +02:00
|
|
|
* @param {any} connectionStream - the stream to mux
|
2020-11-10 18:30:41 +01:00
|
|
|
* @returns {stream.Stream} the multiplexed stream
|
2018-04-16 17:29:43 +02:00
|
|
|
*/
|
2020-11-03 00:41:28 +01:00
|
|
|
export function setupMultiplex(connectionStream) {
|
2021-02-04 19:15:23 +01:00
|
|
|
const mux = new ObjectMultiplex();
|
2020-11-03 00:41:28 +01:00
|
|
|
pump(connectionStream, mux, connectionStream, (err) => {
|
|
|
|
if (err) {
|
2021-02-04 19:15:23 +01:00
|
|
|
console.error(err);
|
2020-11-03 00:41:28 +01:00
|
|
|
}
|
2021-02-04 19:15:23 +01:00
|
|
|
});
|
|
|
|
return mux;
|
2016-06-21 22:18:32 +02:00
|
|
|
}
|