muxjs

NodeJS duplex streams multiplexer

Simple examle:

import mux from "@lis355/muxjs";

const mux1 = new mux();
const mux2 = new mux();

mux2
	.on("stream", stream => {
		console.log(`mux2 stream ${stream.id} opened`);

		stream
			.on("data", data => {
				console.log(`mux2 stream ${stream.id} data: ${data}`);

				stream.write("PONG");
				stream.end();
			})
			.on("end", () => console.log(`mux2 stream ${stream.id} closed`));
	});

mux1
	.pipe(mux2)
	.pipe(mux1);

const stream = mux1.openStream();
console.log(`mux1 stream ${stream.id} opened`);

stream
	.on("data", data => {
		console.log(`mux1 stream ${stream.id} data: ${data}`);
	})
	.on("end", () => console.log(`mux1 stream ${stream.id} closed`));

stream.write("PING");

Output will be:

mux1 stream 42733:0 opened
mux2 stream 42733:0 opened
mux2 stream 42733:0 data: PING
mux1 stream 42733:0 data: PONG
mux2 stream 42733:0 closed
mux1 stream 42733:0 closed

Where 42733:0 is the stream internal id