gistfile1.txt

    stream.pipe = function (target, opts) {
        if (!(opts && opts.end === false)) {
            reemit(stream, target, ["end"])
        }
        targets.push(target)

        target.emit("pipe", stream)

        if (flowing === false) {
            flow()
        }

        return target

        function flow() {
            var chunk = stream.read()
                , terminate = false
                , count = 0

            while (chunk) {
                targets.forEach(writeToTarget)
                if (terminate) {
                    return
                }
                chunk = stream.read()
            }
            stream.once("readable", flow)

            function writeToTarget(target) {
                var written = target.write(chunk)
                if (!written) {
                    count++
                    terminate = true
                    target.once("drain", next)
                }
            }

            function next() {
                if (--count === 0) {
                    flow()
                }
            }
        }
    }