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);

    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");
    })
}