streamclient.js

var MuxDemux = require('mux-demux');
var net = require('net');
var BufferStream = require("buffer-stream")

function StreamConnection() {
    var mdm1 = MuxDemux();

    var con = net.connect(8642);
    con.pipe(mdm1).pipe(con);

    var bufferStream = BufferStream().buffer();

    var ds1 = mdm1.createStream('update');
    ds1.pipe(bufferStream).pipe(ds1);

    setInterval(function () {
        bufferStream.write("test");
    }, 3 * 1e3);
}

StreamConnection();
StreamConnection();
StreamConnection();
StreamConnection();
StreamConnection();