multi-stream-shoe-server.js

var shoe = require("./mux-demux-shoe")
    , through = require("through")
    , multiStreamRegExp = /(multi-stream-)([\w\W]*)/
    , streams = {}

module.exports = createShoeConnection

function createShoeConnection(callback) {
    var sock = shoe(proxyConnections)

    return sock

    function proxyConnections(stream) {
        var meta = stream.meta

        if (typeof meta !== "string") {
            return callback(stream)
        }

        var regExpResult = meta.match(multiStreamRegExp)

        if (regExpResult === null) {
            return callback(stream)
        }

        var name = regExpResult[2]
            , communicationStream = streams[name]

        if (!communicationStream) {
            communicationStream = streams[name] = dataOnlyStream()
        }

        stream.pipe(communicationStream).pipe(stream)
    }
}

function dataOnlyStream() {
    return through(write, noop)
}

function write(data) {
    this.emit("data", data)
}

function noop() {}