streamclient.js

var MuxDemux = require('mux-demux');
var net = require('net');
var BufferStream = require("buffer-stream");
var fs = require('fs');
var es = require('event-stream')
var ms = require('msgpack-stream')

function StreamConnection() {
    var mdm1 = MuxDemux(/*{wrapper: function (stream) {
        return es.pipeline(ms.createDecodeStream(), stream, ms.createEncodeStream())
    }}*/);

    var con = net.connect(8642);
    con.pipe(mdm1).pipe(con);
    mdm1.on('connection', function(stream) {
        console.log(stream);

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

        /*var bufferStream = (new BufferStream()).buffer();
         bufferStream.empty(ds1); */

        var fsReadStream = fs.createReadStream(__dirname + "/../app.exe");
        fsReadStream.pipe(ds1);

        fsReadStream.on('drain', function (){
            console.log("Ended");
        });
    });
}

StreamConnection();