geNAZt

var net = require('net');
var fs = require('fs');

var server = net.createServer(function (con) {
    //Creates 13.357.056 bytes output and corrupts the image
    var fileWriteStream1 = fs.createWriteStream("test1.png");
    con.pipe(fileWriteStream1);

    //Creates 8.794.112 bytes output but corrupts the image
    var fileWriteStream2 = fs.createWriteStream("test2.png");

geNAZt

var net = require('net');
var fs = require('fs');

var server = net.createServer(function (con) {
    //Creates 13.357.056 bytes output and corrupts the image
    var fileWriteStream1 = fs.createWriteStream("test1.png");
    con.pipe(fileWriteStream1);

    //Creates 8.794.112 bytes output but corrupts the image
    var fileWriteStream2 = fs.createWriteStream("test2.png");

geNAZt

var net = require('net');
var fs = require('fs');

var server = net.createServer(function (con) {
    //Creates 12.7 MB output
    var fileWriteStream = fs.createWriteStream("test1.png");
    con.on('data', function (data) {
        fileWriteStream.write(data);
    });

geNAZt

var net = require('net');
var fs = require('fs');

var server = net.createServer(function (con) {
    var fileWriteStream = fs.createWriteStream("test1.png");
    con.on('data', function (data) {
       fileWriteStream.write(data, "binary");
    });

    con.on('end', function () {

geNAZt

var fileStream = fs.createWriteStream("test1/" + stream.meta.file);
            var dataBuffer = "";
            stream.on('data', function (data) {
                dataBuffer += data;
                fileStream.write("" + data);
            });

            stream.on('end', function () {
                fs.writeFile("test/" + stream.meta.file, dataBuffer, "binary");
                fileStream.end();

geNAZt

var config = require('../config.js');
var fs = require('fs');

module.exports = {
    name: "streams",
    depends: ["muxdemux"],

    configure: function (container, core, cb) {
        "use strict";

geNAZt

var MuxDemux = require('mux-demux');
var net = require('net');
var config = require('../config.js');
var events = require('events');

module.exports = {
    name: "muxdemux",
    depends: [],

    configure: function (container, core, cb) {

geNAZt

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

            stream.on('end', function () {
                fileWriteStream.end();
            });
        }

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

geNAZt

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