/* channelDefs - is an array of object literals which specify channel and topic
   onSuccess   - invoked once all the messages have successfully arrived
                 (note: onSuccess will receive the data from each individual subscription, as args, in order)
   onError     - [optional] - invoked if the operation fails (currently only a timeout fails the operation)
   options     - [optional] - can provide the following:
                 {
                    once: true,     // if true, the 'fork/join" process is only run once
                                    // and not reset afterwards to run again
                    timeout: 2000,  // a timeout value in milliseconds.  It fires the onError
                                    // callback if the timeout occurs before all messages have arrived
                 }
*/
postal.when(channelDefs, onSuccess, onError, options);
postal.when(channelDefs, onSuccess, options);
postal.when(channelDefs, onSuccess, onError);
postal.when(channelDefs, onSuccess);

postal.when([
    { channel: "ChannelA", topic: "topic.on.channel.a" },
    { channel: "ChannelB", topic: "topic.on.channel.b" },
    { channel: "ChannelC", topic: "topic.on.channel.c" },
    { channel: "ChannelD", topic: "topic.on.channel.d" },
], function(a, b, c, d){
    _.each(arguments, function(x) {
        $('body').append("<div>" + x + "</div>");
    });
});
 
postal.publish( { channel: "ChannelD", topic: "topic.on.channel.d", data: "And it's testable!" } );
postal.publish( { channel: "ChannelB", topic: "topic.on.channel.b", data: "Deferred behavior!" } );
postal.publish( { channel: "ChannelA", topic: "topic.on.channel.a", data: "Hey look!" } );
postal.publish( { channel: "ChannelC", topic: "topic.on.channel.c", data: "Via message bus!" } );

// this is assuming underscore and postal have been required above somewhere...
var postal = require("postal");
var postalWhen = require("path/to/postal/when")(postal);