summaryrefslogtreecommitdiff
path: root/js/dojo/dojox/lang/async
diff options
context:
space:
mode:
Diffstat (limited to 'js/dojo/dojox/lang/async')
-rw-r--r--js/dojo/dojox/lang/async/event.js46
-rw-r--r--js/dojo/dojox/lang/async/timeout.js45
-rw-r--r--js/dojo/dojox/lang/async/topic.js45
3 files changed, 136 insertions, 0 deletions
diff --git a/js/dojo/dojox/lang/async/event.js b/js/dojo/dojox/lang/async/event.js
new file mode 100644
index 0000000..a3122a3
--- /dev/null
+++ b/js/dojo/dojox/lang/async/event.js
@@ -0,0 +1,46 @@
+//>>built
+// wrapped by build app
+define("dojox/lang/async/event", ["dijit","dojo","dojox"], function(dijit,dojo,dojox){
+dojo.provide("dojox.lang.async.event");
+
+// Source of Deferred for events
+
+(function(){
+ var d = dojo, event = dojox.lang.async.event;
+
+ event.from = function(src, name){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ d.disconnect(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = d.connect(src, name, function(evt){
+ cancel();
+ x.callback(evt);
+ });
+ return x;
+ };
+ };
+
+ event.failOn = function(src, name){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ d.disconnect(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = d.connect(src, name, function(evt){
+ cancel();
+ x.errback(new Error(evt));
+ });
+ return x;
+ };
+ };
+})();
+
+});
diff --git a/js/dojo/dojox/lang/async/timeout.js b/js/dojo/dojox/lang/async/timeout.js
new file mode 100644
index 0000000..7c5b69d
--- /dev/null
+++ b/js/dojo/dojox/lang/async/timeout.js
@@ -0,0 +1,45 @@
+//>>built
+// wrapped by build app
+define("dojox/lang/async/timeout", ["dijit","dojo","dojox"], function(dijit,dojo,dojox){
+dojo.provide("dojox.lang.async.timeout");
+
+// Source of Deferred for timeouts
+
+(function(){
+ var d = dojo, timeout = dojox.lang.async.timeout;
+
+ timeout.from = function(ms){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ clearTimeout(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = setTimeout(function(){
+ cancel();
+ x.callback(ms);
+ }, ms);
+ return x;
+ };
+ };
+
+ timeout.failOn = function(ms){
+ return function(){
+ var h, cancel = function(){
+ if(h){
+ clearTimeout(h);
+ h = null;
+ }
+ },
+ x = new d.Deferred(cancel);
+ h = setTimeout(function(){
+ cancel();
+ x.errback(ms);
+ }, ms);
+ return x;
+ };
+ };
+})();
+});
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;
+ };
+ };
+})();
+});