Deferred.js
上传用户:kimgenplus
上传日期:2016-06-05
资源大小:20877k
文件大小:4k
源码类别:

OA系统

开发平台:

Java

  1. /*
  2. Copyright (c) 2004-2006, The Dojo Foundation
  3. All Rights Reserved.
  4. Licensed under the Academic Free License version 2.1 or above OR the
  5. modified BSD license. For more information on Dojo licensing, see:
  6. http://dojotoolkit.org/community/licensing.shtml
  7. */
  8. dojo.provide("dojo.Deferred");
  9. dojo.require("dojo.lang.func");
  10. dojo.Deferred = function (canceller) {
  11. this.chain = [];
  12. this.id = this._nextId();
  13. this.fired = -1;
  14. this.paused = 0;
  15. this.results = [null, null];
  16. this.canceller = canceller;
  17. this.silentlyCancelled = false;
  18. };
  19. dojo.lang.extend(dojo.Deferred, {getFunctionFromArgs:function () {
  20. var a = arguments;
  21. if ((a[0]) && (!a[1])) {
  22. if (dojo.lang.isFunction(a[0])) {
  23. return a[0];
  24. } else {
  25. if (dojo.lang.isString(a[0])) {
  26. return dj_global[a[0]];
  27. }
  28. }
  29. } else {
  30. if ((a[0]) && (a[1])) {
  31. return dojo.lang.hitch(a[0], a[1]);
  32. }
  33. }
  34. return null;
  35. }, makeCalled:function () {
  36. var deferred = new dojo.Deferred();
  37. deferred.callback();
  38. return deferred;
  39. }, repr:function () {
  40. var state;
  41. if (this.fired == -1) {
  42. state = "unfired";
  43. } else {
  44. if (this.fired == 0) {
  45. state = "success";
  46. } else {
  47. state = "error";
  48. }
  49. }
  50. return "Deferred(" + this.id + ", " + state + ")";
  51. }, toString:dojo.lang.forward("repr"), _nextId:(function () {
  52. var n = 1;
  53. return function () {
  54. return n++;
  55. };
  56. })(), cancel:function () {
  57. if (this.fired == -1) {
  58. if (this.canceller) {
  59. this.canceller(this);
  60. } else {
  61. this.silentlyCancelled = true;
  62. }
  63. if (this.fired == -1) {
  64. this.errback(new Error(this.repr()));
  65. }
  66. } else {
  67. if ((this.fired == 0) && (this.results[0] instanceof dojo.Deferred)) {
  68. this.results[0].cancel();
  69. }
  70. }
  71. }, _pause:function () {
  72. this.paused++;
  73. }, _unpause:function () {
  74. this.paused--;
  75. if ((this.paused == 0) && (this.fired >= 0)) {
  76. this._fire();
  77. }
  78. }, _continue:function (res) {
  79. this._resback(res);
  80. this._unpause();
  81. }, _resback:function (res) {
  82. this.fired = ((res instanceof Error) ? 1 : 0);
  83. this.results[this.fired] = res;
  84. this._fire();
  85. }, _check:function () {
  86. if (this.fired != -1) {
  87. if (!this.silentlyCancelled) {
  88. dojo.raise("already called!");
  89. }
  90. this.silentlyCancelled = false;
  91. return;
  92. }
  93. }, callback:function (res) {
  94. this._check();
  95. this._resback(res);
  96. }, errback:function (res) {
  97. this._check();
  98. if (!(res instanceof Error)) {
  99. res = new Error(res);
  100. }
  101. this._resback(res);
  102. }, addBoth:function (cb, cbfn) {
  103. var enclosed = this.getFunctionFromArgs(cb, cbfn);
  104. if (arguments.length > 2) {
  105. enclosed = dojo.lang.curryArguments(null, enclosed, arguments, 2);
  106. }
  107. return this.addCallbacks(enclosed, enclosed);
  108. }, addCallback:function (cb, cbfn) {
  109. var enclosed = this.getFunctionFromArgs(cb, cbfn);
  110. if (arguments.length > 2) {
  111. enclosed = dojo.lang.curryArguments(null, enclosed, arguments, 2);
  112. }
  113. return this.addCallbacks(enclosed, null);
  114. }, addErrback:function (cb, cbfn) {
  115. var enclosed = this.getFunctionFromArgs(cb, cbfn);
  116. if (arguments.length > 2) {
  117. enclosed = dojo.lang.curryArguments(null, enclosed, arguments, 2);
  118. }
  119. return this.addCallbacks(null, enclosed);
  120. return this.addCallbacks(null, cbfn);
  121. }, addCallbacks:function (cb, eb) {
  122. this.chain.push([cb, eb]);
  123. if (this.fired >= 0) {
  124. this._fire();
  125. }
  126. return this;
  127. }, _fire:function () {
  128. var chain = this.chain;
  129. var fired = this.fired;
  130. var res = this.results[fired];
  131. var self = this;
  132. var cb = null;
  133. while (chain.length > 0 && this.paused == 0) {
  134. var pair = chain.shift();
  135. var f = pair[fired];
  136. if (f == null) {
  137. continue;
  138. }
  139. try {
  140. res = f(res);
  141. fired = ((res instanceof Error) ? 1 : 0);
  142. if (res instanceof dojo.Deferred) {
  143. cb = function (res) {
  144. self._continue(res);
  145. };
  146. this._pause();
  147. }
  148. }
  149. catch (err) {
  150. fired = 1;
  151. res = err;
  152. }
  153. }
  154. this.fired = fired;
  155. this.results[fired] = res;
  156. if ((cb) && (this.paused)) {
  157. res.addBoth(cb);
  158. }
  159. }});