geNAZt

var MuxDemux = require('mux-demux');
var net = require('net');

var mdm = MuxDemux(function (stream) {
        console.log("Connection: ", stream);
        stream.on('data', function (data) {
            console.log(data);
        });
    })

geNAZt

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

net.createServer(function (con) {
    var mdm = MuxDemux({wrapper: function (stream) {
        return es.pipeline(ms.createDecodeStream(), stream, ms.createEncodeStream())
    }}, function (stream) {
        console.log("Connection: ", stream);

geNAZt

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

geNAZt

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

net.createServer(function (con) {
    var mdm = MuxDemux();
    con.pipe(mdm).pipe(con);

    mdm.on('connection', function (stream) {

geNAZt

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

geNAZt

function setFileStream(stream) {
            stream.dataHandler = null;
            stream.fileName = null;
            stream.currentData = null;

            stream.on('data', function (data) {
                if (data.type == "start") {
                    stream.fileName = data.file;
                    stream.dataHandler = function (data) {
                        if (stream.currentData === null) {

geNAZt

function setFileStream(stream) {
            stream.fileStream = null;
            stream.dataHandler = null;

            stream.on('data', function (data) {
                if (data.type == "start") {
                    stream.fileStream = fs.createWriteStream(data.file);
                    stream.dataHandler = function (data) {
                        stream.fileStream.write(data);
                    };

geNAZt

var MuxDemux = require('mux-demux');
var net = require('net');
var fs = require('fs');

function StreamConnection() {
    var con = net.connect(12345, function() {
        var mdm1 = MuxDemux();
        con.pipe(mdm1).pipe(con);

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

geNAZt

function setFileStream(stream) {
            var fileWriteStream = fs.createWriteStream(stream.meta.file, {encoding: 'binary'});
            stream.pipe(fileWriteStream);
        }

geNAZt

 function sendFile(file, cb) {
            var ds1 = mdm1.createStream({type: 'update', file: file});

            var fsReadStream = fs.createReadStream(__dirname + "/" + file, {encoding: "binary"});
            fsReadStream.pipe(ds1);

            cb();
        }

        sendFile("test.png", function() {