mux-demux-shoe-client.js

var shoe = require("shoe")
    , MuxDemux = require("mux-demux")

module.exports = createShoeStream

function createShoeStream(uri) {
    var stream = shoe(uri)
        , mdm = MuxDemux()

    mdm.pipe(stream).pipe(mdm)

    return mdm
}

mux-demux-shoe-server.js

var shoe = require("shoe")
    , MuxDemux = require("mux-demux")

module.exports = createShoeConnection

function createShoeConnection(options, callback) {
    if (typeof options === 'function') {
        callback = options
        options = {}
    }

    return shoe(options, interceptStream)

    function interceptStream(stream) {
        var mdm = MuxDemux()

        mdm.on("connection", callback)

        stream.pipe(mdm).pipe(stream)
    }
}