summaryrefslogtreecommitdiff
path: root/js/dojo/dojox/lang/async/topic.js
diff options
context:
space:
mode:
Diffstat (limited to 'js/dojo/dojox/lang/async/topic.js')
-rw-r--r--js/dojo/dojox/lang/async/topic.js45
1 files changed, 45 insertions, 0 deletions
diff --git a/js/dojo/dojox/lang/async/topic.js b/js/dojo/dojox/lang/async/topic.js
new file mode 100644
index 0000000..b2ac15e
--- /dev/null
+++ b/js/dojo/dojox/lang/async/topic.js
@@ -0,0 +1,45 @@
+//>>built
+// wrapped by build app
+define("dojox/lang/async/topic", ["dijit","dojo","dojox"], function(dijit,dojo,dojox){
+dojo.provide("dojox.lang.async.topic");
+
+// Source of Deferred for topics
+
+(function(){
+ var d = dojo, topic = dojox.lang.async.topic;
+
+ topic.from = function(topic){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ d.unsubscribe(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = d.subscribe(topic, function(){
+ cancel();
+ x.callback(arguments);
+ });
+ return x;
+ };
+ };
+
+ topic.failOn = function(topic){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ d.unsubscribe(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = d.subscribe(topic, function(evt){
+ cancel();
+ x.errback(new Error(arguments));
+ });
+ return x;
+ };
+ };
+})();
+});