Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- // Temporary publish() to queue up messages until connection to Genericore
- // is ready.
- var publish_queue = [];
- var publish_enqueue = function (message) {
- publish_queue.push(message);
- log('enqueue: ' + publish_queue.length);
- };
- var publish = publish_enqueue;
- var ready = function (client) {
- // bind real publish function and flush publish_queue to Genericore.
- publish = client.publish;
- for (var i = 0; i < publish_queue.length; ++i) {
- log('dequeue: ' + i + '/' + publish_queue.length);
- publish(publish_queue[i]);
- };
- publish_queue = [];
- };
Add Comment
Please, Sign In to add comment