Closed avishnyak closed 8 years ago
Merged @avishnyak thx :) Ps: Great, now we can support pub/sub Ps2: I think send should always return a promise (right now you're returning an array of promises), so probably the best thing to do is add a Studio.promise.all(resultts) in the return
@avishnyak published your PRs to npm
Thanks! I'll make the change to return promises asap.
Apologies for the crazy pull-requests. I'm obviously not a pro at using GitHub to branch/rebase yet.
This is a balance module that lets you multiplex a single message to all listeners on a given route. All other traffic goes to the "passThrough" module you can configure. This would be good for the map in map->reduce because all of the results come back in an array. I can imagine having a query service running on a dozen machines. You multiplex the query, get the results from each and then reduce locally.
That would actually probably be a good example to add... I'll do that next.