Added one-time subscription to event-queue with "once". Need tests.

This commit is contained in:
Christoph Oberhofer
2014-12-17 23:20:51 +01:00
parent 005a989aa3
commit 480e962ea8
6 changed files with 74 additions and 42 deletions
+33 -19
View File
@@ -25,30 +25,44 @@ define(function() {
subscription.callback.call(null, data);
}
}
function subscribe(event, callback, async) {
var subscription;
if ( typeof callback === "function") {
subscription = {
callback : callback,
async : async
};
} else {
subscription = callback;
if (!subscription.callback) {
throw "Callback was not specified on options";
}
}
getEvent(event).subscribers.push(subscription);
}
return {
subscribe : function(event, callback, async) {
var subscription;
if ( typeof callback === "function") {
subscription = {
callback : callback,
async : async
};
} else {
subscription = callback;
if (!subscription.callback) {
throw "Callback was not specified on options";
}
}
getEvent(event).subscribers.push(subscription);
return subscribe(event, callback, async);
},
publish : function(eventName, data) {
var subscribers = getEvent(eventName).subscribers, i;
for ( i = 0; i < subscribers.length; i++) {
publishSubscription(subscribers[i], data);
}
var event = getEvent(eventName),
subscribers = event.subscribers;
event.subscribers = subscribers.filter(function(subscriber) {
publishSubscription(subscriber, data);
return !subscriber.once;
});
},
once: function(event, callback, async) {
subscribe(event, {
callback: callback,
async: async,
once: true
});
}
};
}();
+1 -1
View File
@@ -213,7 +213,7 @@ function(Code128Reader, EANReader, InputStream, ImageWrapper, BarcodeLocator, Ba
size: 800
};
config.readyFunc = function() {
Events.subscribe("detected", function(result) {
Events.once("detected", function(result) {
_stopped = true;
resultCallback.call(null, result);
}, true);