• Jump To … +
    descend.js indexify.js listen.bin.js listener.js map.js mock.js mock2.js monitor.js olio.bin.js olio.js prolific.configure.js run.bin.js runner.js search.js serve.bin.js serve.child.js server.js
  • descend.js

  • ¶
    var coalesce = require('extant')
    
    module.exports = function (descendent, pids) {
        return function (path, message, handle) {
            if (message.to == null) {
                for (var i = 0, pid; (pid = pids[i]) != null; i++) {
                    descendent.down([ pid ], 'olio:message', message, coalesce(handle))
                }
            } else {
                descendent.down([ pids[message.to.index % pids.length] ], 'olio:message', message, coalesce(handle))
            }
        }
    }