yamux

yamux

Yet another stream multiplexer. Requires node v0.10.x

Why

An implementation that can handle partial packets.

Basic concept

Client side

• Create a multiplex stream and pipe it into a common channel.
• Create virtual streams off the multiplex stream and use them to interleave data over the common channel

var Multiplex = require('yamux');
var plexer = new Multiplex();
plexer.pipe(commonXXXChannel);

var virtualStream1 = plexer.createStream();
var virtualStream2 = plexer.createStream();
virtualStream1.write('Yamuuuuuuuuxxxx!!!');
virtualStream2.write('Lamux!');

Server side

• Create a multiplex stream and register an "onStream" handler with it.
• The onStream handler will get triggered when a new virtual stream is available.
• Pipe the common channel into the multiplex stream.

var Multiplex = require('yamux');
var plexer = new Multiplex(function(virtualStream) {
  virtualStream.pipe(process.stdout);
});

commonXXXChannel.pipe(plexer);

Now, go Enjoy your lunch.

Example

// on the client side
var net = require('net');
var fs = rquire('fs');
var Multiplex = require('yamux');

var plexer = new Multiplex();
var client = net.connect({ host: 'someehost.no.where', port: 1337});

plexer.pipe(client).pipe(plexer);

// pipe three files over the tcp connection
var file1 = fs.createReadStream(__dirname + '/file1');
var file2 = fs.createReadStream(__dirname + '/file2');
var file3 = fs.createReadStream(__dirname + '/file3');

file1.pipe(plexer.createStream());
file2.pipe(plexer.createStream());
file3.pipe(plexer.createStream());

//////////////////
// on the server side
var net = require('net');
var fs = rquire('fs');
var Multiplex = require('yamux');
var fileIndex = 1;

var plexer = new Multiplex(function(stream) {
  var file = fs.createWriteStream(__dirname + '/file' + fileIndex++);
  stream.pipe(file);
});

var server = net.createServer(function(c) {
  c.pipe(plexer).pipe(c);
});

server.listen(1337);

License

MIT