mirror of
https://github.com/kremalicious/metamask-extension.git
synced 2024-11-29 23:58:06 +01:00
18 lines
451 B
JavaScript
18 lines
451 B
JavaScript
import ObjectMultiplex from 'obj-multiplex';
|
|
import pump from 'pump';
|
|
|
|
/**
|
|
* Sets up stream multiplexing for the given stream
|
|
* @param {any} connectionStream - the stream to mux
|
|
* @returns {stream.Stream} the multiplexed stream
|
|
*/
|
|
export function setupMultiplex(connectionStream) {
|
|
const mux = new ObjectMultiplex();
|
|
pump(connectionStream, mux, connectionStream, (err) => {
|
|
if (err) {
|
|
console.error(err);
|
|
}
|
|
});
|
|
return mux;
|
|
}
|