multiplex memory leak

test.js

var multiplex = require('multiplex');
var debug = require('debug')('test')

var plex1 = multiplex();
var plex2 = multiplex()
plex1.pipe(plex2);
plex2.pipe(plex1);

function createStream(name) {

    var stream = plex1.createSharedStream(name);
    stream.on("data", function (data) {
        debug("Got data");
        debug(data);
    });

    stream.on("end", function (data) {
        debug("stream ended");
        stream.destroy();
    });

    var secondStream = plex2.createSharedStream(name);
    secondStream.on("data", function (data) {
        debug("second stream got data");
    });
    secondStream.on("data", function (data) {
        debug("second stream got end");
        secondStream.end(new Buffer("End of this stream"));
    });

    console.log(plex1);
    debug("x");
    stream.end(new Buffer("Hello World"));

}

createStream("foo");
createStream("bar");

setTimeout(function () {
    console.log(plex1);
}, 1000);