Axon.js 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720
  1. define(["amber/boot", "amber_core/Kernel-Exceptions", "amber_core/Kernel-Objects"], function($boot){"use strict";
  2. if(!$boot.nilAsReceiver)$boot.nilAsReceiver=$boot.nil;
  3. if(!("nilAsValue" in $boot))$boot.nilAsValue=$boot.nilAsReceiver;
  4. var $core=$boot.api,nil=$boot.nilAsValue,$nil=$boot.nilAsReceiver,$recv=$boot.asReceiver,$globals=$boot.globals;
  5. if(!$boot.nilAsClass)$boot.nilAsClass=$boot.dnu;
  6. $core.addPackage("Axon");
  7. $core.packages["Axon"].innerEval = function (expr) { return eval(expr); };
  8. $core.packages["Axon"].transport = {"type":"amd","amdNamespace":"axon"};
  9. $core.addClass("Axon", $globals.Object, ["factory"], "Axon");
  10. //>>excludeStart("ide", pragmas.excludeIdeData);
  11. $globals.Axon.comment="I represent a pub-sub based on a key (called 'aspect').\x0aI manage aspect-block subscriptions (called 'interests') as well as run blocks of dirtied interests.\x0aThe interest objects are responsible of decision if the change of an aspect is relevant for them.\x0aInterest object must be subclasses of `AxonInterest`.\x0a\x0aMy subclasses must provide implementation for:\x0a\x0a - add:\x0a - do:\x0a - clean";
  12. //>>excludeEnd("ide");
  13. $core.addMethod(
  14. $core.method({
  15. selector: "addInterest:",
  16. protocol: "action",
  17. fn: function (anInterest){
  18. var self=this,$self=this;
  19. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  20. return $core.withContext(function($ctx1) {
  21. //>>excludeEnd("ctx");
  22. var $1;
  23. $recv(anInterest)._flag();
  24. $1=$recv(anInterest)._yourself();
  25. $self._add_($1);
  26. $self._dirty_(true);
  27. return self;
  28. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  29. }, function($ctx1) {$ctx1.fill(self,"addInterest:",{anInterest:anInterest},$globals.Axon)});
  30. //>>excludeEnd("ctx");
  31. },
  32. //>>excludeStart("ide", pragmas.excludeIdeData);
  33. args: ["anInterest"],
  34. source: "addInterest: anInterest\x0a\x09self\x0a\x09\x09add: (anInterest flag; yourself);\x0a\x09\x09dirty: true",
  35. referencedClasses: [],
  36. //>>excludeEnd("ide");
  37. messageSends: ["add:", "flag", "yourself", "dirty:"]
  38. }),
  39. $globals.Axon);
  40. $core.addMethod(
  41. $core.method({
  42. selector: "changed:",
  43. protocol: "action",
  44. fn: function (anAspect){
  45. var self=this,$self=this;
  46. var needsToRun;
  47. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  48. return $core.withContext(function($ctx1) {
  49. //>>excludeEnd("ctx");
  50. var $1;
  51. needsToRun=false;
  52. $self._do_((function(each){
  53. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  54. return $core.withContext(function($ctx2) {
  55. //>>excludeEnd("ctx");
  56. $1=$recv(each)._accepts_(anAspect);
  57. if($core.assert($1)){
  58. $recv(each)._flag();
  59. needsToRun=true;
  60. return needsToRun;
  61. }
  62. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  63. }, function($ctx2) {$ctx2.fillBlock({each:each},$ctx1,1)});
  64. //>>excludeEnd("ctx");
  65. }));
  66. $self._dirty_(needsToRun);
  67. return self;
  68. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  69. }, function($ctx1) {$ctx1.fill(self,"changed:",{anAspect:anAspect,needsToRun:needsToRun},$globals.Axon)});
  70. //>>excludeEnd("ctx");
  71. },
  72. //>>excludeStart("ide", pragmas.excludeIdeData);
  73. args: ["anAspect"],
  74. source: "changed: anAspect\x0a\x09| needsToRun |\x0a\x09needsToRun := false.\x0a\x09self do: [ :each |\x0a\x09\x09(each accepts: anAspect) ifTrue: [\x0a\x09\x09\x09each flag.\x0a\x09\x09\x09needsToRun := true ]].\x0a\x09self dirty: needsToRun",
  75. referencedClasses: [],
  76. //>>excludeEnd("ide");
  77. messageSends: ["do:", "ifTrue:", "accepts:", "flag", "dirty:"]
  78. }),
  79. $globals.Axon);
  80. $core.addMethod(
  81. $core.method({
  82. selector: "changedAll",
  83. protocol: "action",
  84. fn: function (){
  85. var self=this,$self=this;
  86. var needsToRun;
  87. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  88. return $core.withContext(function($ctx1) {
  89. //>>excludeEnd("ctx");
  90. needsToRun=false;
  91. $self._do_((function(each){
  92. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  93. return $core.withContext(function($ctx2) {
  94. //>>excludeEnd("ctx");
  95. $recv(each)._flag();
  96. needsToRun=true;
  97. return needsToRun;
  98. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  99. }, function($ctx2) {$ctx2.fillBlock({each:each},$ctx1,1)});
  100. //>>excludeEnd("ctx");
  101. }));
  102. $self._dirty_(needsToRun);
  103. return self;
  104. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  105. }, function($ctx1) {$ctx1.fill(self,"changedAll",{needsToRun:needsToRun},$globals.Axon)});
  106. //>>excludeEnd("ctx");
  107. },
  108. //>>excludeStart("ide", pragmas.excludeIdeData);
  109. args: [],
  110. source: "changedAll\x0a\x09| needsToRun |\x0a\x09needsToRun := false.\x0a\x09self do: [ :each |\x0a\x09\x09each flag.\x0a\x09\x09needsToRun := true ].\x0a\x09self dirty: needsToRun",
  111. referencedClasses: [],
  112. //>>excludeEnd("ide");
  113. messageSends: ["do:", "flag", "dirty:"]
  114. }),
  115. $globals.Axon);
  116. $core.addMethod(
  117. $core.method({
  118. selector: "dirty:",
  119. protocol: "action",
  120. fn: function (aBoolean){
  121. var self=this,$self=this;
  122. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  123. return $core.withContext(function($ctx1) {
  124. //>>excludeEnd("ctx");
  125. if($core.assert(aBoolean)){
  126. $recv((function(){
  127. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  128. return $core.withContext(function($ctx2) {
  129. //>>excludeEnd("ctx");
  130. return $self._run();
  131. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  132. }, function($ctx2) {$ctx2.fillBlock({},$ctx1,2)});
  133. //>>excludeEnd("ctx");
  134. }))._fork();
  135. }
  136. return self;
  137. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  138. }, function($ctx1) {$ctx1.fill(self,"dirty:",{aBoolean:aBoolean},$globals.Axon)});
  139. //>>excludeEnd("ctx");
  140. },
  141. //>>excludeStart("ide", pragmas.excludeIdeData);
  142. args: ["aBoolean"],
  143. source: "dirty: aBoolean\x0a\x09aBoolean ifTrue: [[ self run ] fork]",
  144. referencedClasses: [],
  145. //>>excludeEnd("ide");
  146. messageSends: ["ifTrue:", "fork", "run"]
  147. }),
  148. $globals.Axon);
  149. $core.addMethod(
  150. $core.method({
  151. selector: "registerIn:",
  152. protocol: "injecting",
  153. fn: function (anObject){
  154. var self=this,$self=this;
  155. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  156. return $core.withContext(function($ctx1) {
  157. //>>excludeEnd("ctx");
  158. anObject.$axon$=self;
  159. return self;
  160. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  161. }, function($ctx1) {$ctx1.fill(self,"registerIn:",{anObject:anObject},$globals.Axon)});
  162. //>>excludeEnd("ctx");
  163. },
  164. //>>excludeStart("ide", pragmas.excludeIdeData);
  165. args: ["anObject"],
  166. source: "registerIn: anObject\x0a<inlineJS: 'anObject.$axon$=self'>",
  167. referencedClasses: [],
  168. //>>excludeEnd("ide");
  169. messageSends: []
  170. }),
  171. $globals.Axon);
  172. $core.addMethod(
  173. $core.method({
  174. selector: "run",
  175. protocol: "action",
  176. fn: function (){
  177. var self=this,$self=this;
  178. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  179. return $core.withContext(function($ctx1) {
  180. //>>excludeEnd("ctx");
  181. var $1,$2,$3;
  182. $recv((function(){
  183. var needsClean;
  184. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  185. return $core.withContext(function($ctx2) {
  186. //>>excludeEnd("ctx");
  187. needsClean=false;
  188. needsClean;
  189. $self._do_((function(each){
  190. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  191. return $core.withContext(function($ctx3) {
  192. //>>excludeEnd("ctx");
  193. $1=$recv(each)._isFlagged();
  194. if($core.assert($1)){
  195. $recv(each)._run();
  196. }
  197. $2=$recv(each)._isEnabled();
  198. if(!$core.assert($2)){
  199. needsClean=true;
  200. return needsClean;
  201. }
  202. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  203. }, function($ctx3) {$ctx3.fillBlock({each:each},$ctx2,2)});
  204. //>>excludeEnd("ctx");
  205. }));
  206. $3=needsClean;
  207. if($core.assert($3)){
  208. return $self._clean();
  209. }
  210. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  211. }, function($ctx2) {$ctx2.fillBlock({needsClean:needsClean},$ctx1,1)});
  212. //>>excludeEnd("ctx");
  213. }))._on_do_($globals.Error,(function(){
  214. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  215. return $core.withContext(function($ctx2) {
  216. //>>excludeEnd("ctx");
  217. return $self._dirty_(true);
  218. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  219. }, function($ctx2) {$ctx2.fillBlock({},$ctx1,6)});
  220. //>>excludeEnd("ctx");
  221. }));
  222. return self;
  223. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  224. }, function($ctx1) {$ctx1.fill(self,"run",{},$globals.Axon)});
  225. //>>excludeEnd("ctx");
  226. },
  227. //>>excludeStart("ide", pragmas.excludeIdeData);
  228. args: [],
  229. source: "run\x0a\x09[\x0a\x09\x09| needsClean |\x0a\x09 needsClean := false.\x0a\x09\x09self do: [ :each |\x0a\x09\x09\x09each isFlagged ifTrue: [ each run ].\x0a\x09 each isEnabled ifFalse: [ needsClean := true ]\x0a\x09\x09].\x0a \x09needsClean ifTrue: [ self clean ]\x0a\x09] on: Error do: [ self dirty: true ]",
  230. referencedClasses: ["Error"],
  231. //>>excludeEnd("ide");
  232. messageSends: ["on:do:", "do:", "ifTrue:", "isFlagged", "run", "ifFalse:", "isEnabled", "clean", "dirty:"]
  233. }),
  234. $globals.Axon);
  235. $core.addClass("DumbAxon", $globals.Axon, [], "Axon");
  236. //>>excludeStart("ide", pragmas.excludeIdeData);
  237. $globals.DumbAxon.comment="I am an axon that does nothing.";
  238. //>>excludeEnd("ide");
  239. $core.addMethod(
  240. $core.method({
  241. selector: "add:",
  242. protocol: "as yet unclassified",
  243. fn: function (anInterest){
  244. var self=this,$self=this;
  245. return self;
  246. },
  247. //>>excludeStart("ide", pragmas.excludeIdeData);
  248. args: ["anInterest"],
  249. source: "add: anInterest\x0a\x09\x22pass\x22",
  250. referencedClasses: [],
  251. //>>excludeEnd("ide");
  252. messageSends: []
  253. }),
  254. $globals.DumbAxon);
  255. $core.addMethod(
  256. $core.method({
  257. selector: "clean",
  258. protocol: "as yet unclassified",
  259. fn: function (){
  260. var self=this,$self=this;
  261. return self;
  262. },
  263. //>>excludeStart("ide", pragmas.excludeIdeData);
  264. args: [],
  265. source: "clean\x0a\x09\x22pass\x22",
  266. referencedClasses: [],
  267. //>>excludeEnd("ide");
  268. messageSends: []
  269. }),
  270. $globals.DumbAxon);
  271. $core.addMethod(
  272. $core.method({
  273. selector: "do:",
  274. protocol: "as yet unclassified",
  275. fn: function (aBlock){
  276. var self=this,$self=this;
  277. return self;
  278. },
  279. //>>excludeStart("ide", pragmas.excludeIdeData);
  280. args: ["aBlock"],
  281. source: "do: aBlock\x0a\x09\x22pass\x22",
  282. referencedClasses: [],
  283. //>>excludeEnd("ide");
  284. messageSends: []
  285. }),
  286. $globals.DumbAxon);
  287. $core.addClass("SimpleAxon", $globals.Axon, ["queue"], "Axon");
  288. $core.addMethod(
  289. $core.method({
  290. selector: "add:",
  291. protocol: "accessing",
  292. fn: function (aSubscription){
  293. var self=this,$self=this;
  294. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  295. return $core.withContext(function($ctx1) {
  296. //>>excludeEnd("ctx");
  297. $recv($self["@queue"])._add_(aSubscription);
  298. return self;
  299. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  300. }, function($ctx1) {$ctx1.fill(self,"add:",{aSubscription:aSubscription},$globals.SimpleAxon)});
  301. //>>excludeEnd("ctx");
  302. },
  303. //>>excludeStart("ide", pragmas.excludeIdeData);
  304. args: ["aSubscription"],
  305. source: "add: aSubscription\x0a\x09queue add: aSubscription.",
  306. referencedClasses: [],
  307. //>>excludeEnd("ide");
  308. messageSends: ["add:"]
  309. }),
  310. $globals.SimpleAxon);
  311. $core.addMethod(
  312. $core.method({
  313. selector: "clean",
  314. protocol: "bookkeeping",
  315. fn: function (){
  316. var self=this,$self=this;
  317. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  318. return $core.withContext(function($ctx1) {
  319. //>>excludeEnd("ctx");
  320. $self["@queue"]=$recv($self["@queue"])._select_((function(each){
  321. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  322. return $core.withContext(function($ctx2) {
  323. //>>excludeEnd("ctx");
  324. return $recv(each)._isEnabled();
  325. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  326. }, function($ctx2) {$ctx2.fillBlock({each:each},$ctx1,1)});
  327. //>>excludeEnd("ctx");
  328. }));
  329. return self;
  330. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  331. }, function($ctx1) {$ctx1.fill(self,"clean",{},$globals.SimpleAxon)});
  332. //>>excludeEnd("ctx");
  333. },
  334. //>>excludeStart("ide", pragmas.excludeIdeData);
  335. args: [],
  336. source: "clean\x0a\x09queue := queue select: [ :each | each isEnabled ]",
  337. referencedClasses: [],
  338. //>>excludeEnd("ide");
  339. messageSends: ["select:", "isEnabled"]
  340. }),
  341. $globals.SimpleAxon);
  342. $core.addMethod(
  343. $core.method({
  344. selector: "do:",
  345. protocol: "enumeration",
  346. fn: function (aBlock){
  347. var self=this,$self=this;
  348. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  349. return $core.withContext(function($ctx1) {
  350. //>>excludeEnd("ctx");
  351. $recv($self["@queue"])._do_(aBlock);
  352. return self;
  353. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  354. }, function($ctx1) {$ctx1.fill(self,"do:",{aBlock:aBlock},$globals.SimpleAxon)});
  355. //>>excludeEnd("ctx");
  356. },
  357. //>>excludeStart("ide", pragmas.excludeIdeData);
  358. args: ["aBlock"],
  359. source: "do: aBlock\x0a\x09queue do: aBlock",
  360. referencedClasses: [],
  361. //>>excludeEnd("ide");
  362. messageSends: ["do:"]
  363. }),
  364. $globals.SimpleAxon);
  365. $core.addMethod(
  366. $core.method({
  367. selector: "initialize",
  368. protocol: "initialization",
  369. fn: function (){
  370. var self=this,$self=this;
  371. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  372. return $core.withContext(function($ctx1) {
  373. //>>excludeEnd("ctx");
  374. (
  375. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  376. $ctx1.supercall = true,
  377. //>>excludeEnd("ctx");
  378. ($globals.SimpleAxon.superclass||$boot.nilAsClass).fn.prototype._initialize.apply($self, []));
  379. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  380. $ctx1.supercall = false;
  381. //>>excludeEnd("ctx");;
  382. $self["@queue"]=$recv($globals.OrderedCollection)._new();
  383. return self;
  384. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  385. }, function($ctx1) {$ctx1.fill(self,"initialize",{},$globals.SimpleAxon)});
  386. //>>excludeEnd("ctx");
  387. },
  388. //>>excludeStart("ide", pragmas.excludeIdeData);
  389. args: [],
  390. source: "initialize\x0a super initialize.\x0a\x09queue := OrderedCollection new",
  391. referencedClasses: ["OrderedCollection"],
  392. //>>excludeEnd("ide");
  393. messageSends: ["initialize", "new"]
  394. }),
  395. $globals.SimpleAxon);
  396. $core.addClass("AxonInterest", $globals.Object, ["aspect", "actionBlock", "flagged"], "Axon");
  397. $core.addMethod(
  398. $core.method({
  399. selector: "accepts:",
  400. protocol: "testing",
  401. fn: function (anAspect){
  402. var self=this,$self=this;
  403. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  404. return $core.withContext(function($ctx1) {
  405. //>>excludeEnd("ctx");
  406. $self._subclassResponsibility();
  407. return self;
  408. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  409. }, function($ctx1) {$ctx1.fill(self,"accepts:",{anAspect:anAspect},$globals.AxonInterest)});
  410. //>>excludeEnd("ctx");
  411. },
  412. //>>excludeStart("ide", pragmas.excludeIdeData);
  413. args: ["anAspect"],
  414. source: "accepts: anAspect\x0a \x22Should return true if change for anAspect is relevant for this AxonInterest\x22\x0a self subclassResponsibility",
  415. referencedClasses: [],
  416. //>>excludeEnd("ide");
  417. messageSends: ["subclassResponsibility"]
  418. }),
  419. $globals.AxonInterest);
  420. $core.addMethod(
  421. $core.method({
  422. selector: "aspect:block:",
  423. protocol: "accessing",
  424. fn: function (anAspect,aBlock){
  425. var self=this,$self=this;
  426. $self["@aspect"]=anAspect;
  427. $self["@actionBlock"]=aBlock;
  428. return self;
  429. },
  430. //>>excludeStart("ide", pragmas.excludeIdeData);
  431. args: ["anAspect", "aBlock"],
  432. source: "aspect: anAspect block: aBlock\x0a\x09aspect := anAspect.\x0a actionBlock := aBlock",
  433. referencedClasses: [],
  434. //>>excludeEnd("ide");
  435. messageSends: []
  436. }),
  437. $globals.AxonInterest);
  438. $core.addMethod(
  439. $core.method({
  440. selector: "flag",
  441. protocol: "accessing",
  442. fn: function (){
  443. var self=this,$self=this;
  444. $self["@flagged"]=true;
  445. return self;
  446. },
  447. //>>excludeStart("ide", pragmas.excludeIdeData);
  448. args: [],
  449. source: "flag\x0a\x09flagged := true",
  450. referencedClasses: [],
  451. //>>excludeEnd("ide");
  452. messageSends: []
  453. }),
  454. $globals.AxonInterest);
  455. $core.addMethod(
  456. $core.method({
  457. selector: "initialize",
  458. protocol: "initialization",
  459. fn: function (){
  460. var self=this,$self=this;
  461. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  462. return $core.withContext(function($ctx1) {
  463. //>>excludeEnd("ctx");
  464. (
  465. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  466. $ctx1.supercall = true,
  467. //>>excludeEnd("ctx");
  468. ($globals.AxonInterest.superclass||$boot.nilAsClass).fn.prototype._initialize.apply($self, []));
  469. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  470. $ctx1.supercall = false;
  471. //>>excludeEnd("ctx");;
  472. $self["@aspect"]=nil;
  473. $self["@actionBlock"]=nil;
  474. $self["@flagged"]=false;
  475. return self;
  476. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  477. }, function($ctx1) {$ctx1.fill(self,"initialize",{},$globals.AxonInterest)});
  478. //>>excludeEnd("ctx");
  479. },
  480. //>>excludeStart("ide", pragmas.excludeIdeData);
  481. args: [],
  482. source: "initialize\x0a\x09super initialize.\x0a aspect := nil.\x0a actionBlock := nil.\x0a flagged := false.",
  483. referencedClasses: [],
  484. //>>excludeEnd("ide");
  485. messageSends: ["initialize"]
  486. }),
  487. $globals.AxonInterest);
  488. $core.addMethod(
  489. $core.method({
  490. selector: "isEnabled",
  491. protocol: "testing",
  492. fn: function (){
  493. var self=this,$self=this;
  494. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  495. return $core.withContext(function($ctx1) {
  496. //>>excludeEnd("ctx");
  497. return $recv($self["@actionBlock"])._notNil();
  498. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  499. }, function($ctx1) {$ctx1.fill(self,"isEnabled",{},$globals.AxonInterest)});
  500. //>>excludeEnd("ctx");
  501. },
  502. //>>excludeStart("ide", pragmas.excludeIdeData);
  503. args: [],
  504. source: "isEnabled\x0a\x09^actionBlock notNil",
  505. referencedClasses: [],
  506. //>>excludeEnd("ide");
  507. messageSends: ["notNil"]
  508. }),
  509. $globals.AxonInterest);
  510. $core.addMethod(
  511. $core.method({
  512. selector: "isFlagged",
  513. protocol: "testing",
  514. fn: function (){
  515. var self=this,$self=this;
  516. return $self["@flagged"];
  517. },
  518. //>>excludeStart("ide", pragmas.excludeIdeData);
  519. args: [],
  520. source: "isFlagged\x0a\x09^flagged",
  521. referencedClasses: [],
  522. //>>excludeEnd("ide");
  523. messageSends: []
  524. }),
  525. $globals.AxonInterest);
  526. $core.addMethod(
  527. $core.method({
  528. selector: "run",
  529. protocol: "action",
  530. fn: function (){
  531. var self=this,$self=this;
  532. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  533. return $core.withContext(function($ctx1) {
  534. //>>excludeEnd("ctx");
  535. $recv((function(){
  536. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  537. return $core.withContext(function($ctx2) {
  538. //>>excludeEnd("ctx");
  539. $self["@flagged"]=false;
  540. $self["@flagged"];
  541. return $recv($self["@actionBlock"])._value();
  542. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  543. }, function($ctx2) {$ctx2.fillBlock({},$ctx1,1)});
  544. //>>excludeEnd("ctx");
  545. }))._on_do_($globals.AxonOff,(function(){
  546. $self["@actionBlock"]=nil;
  547. return $self["@actionBlock"];
  548. }));
  549. return self;
  550. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  551. }, function($ctx1) {$ctx1.fill(self,"run",{},$globals.AxonInterest)});
  552. //>>excludeEnd("ctx");
  553. },
  554. //>>excludeStart("ide", pragmas.excludeIdeData);
  555. args: [],
  556. source: "run\x0a\x09[ flagged := false. actionBlock value ]\x0a on: AxonOff do: [ actionBlock := nil ]",
  557. referencedClasses: ["AxonOff"],
  558. //>>excludeEnd("ide");
  559. messageSends: ["on:do:", "value"]
  560. }),
  561. $globals.AxonInterest);
  562. $core.addClass("InterestedInEqual", $globals.AxonInterest, [], "Axon");
  563. $core.addMethod(
  564. $core.method({
  565. selector: "accepts:",
  566. protocol: "testing",
  567. fn: function (anAspect){
  568. var self=this,$self=this;
  569. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  570. return $core.withContext(function($ctx1) {
  571. //>>excludeEnd("ctx");
  572. return $recv(anAspect).__eq($self["@aspect"]);
  573. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  574. }, function($ctx1) {$ctx1.fill(self,"accepts:",{anAspect:anAspect},$globals.InterestedInEqual)});
  575. //>>excludeEnd("ctx");
  576. },
  577. //>>excludeStart("ide", pragmas.excludeIdeData);
  578. args: ["anAspect"],
  579. source: "accepts: anAspect\x0a ^ anAspect = aspect",
  580. referencedClasses: [],
  581. //>>excludeEnd("ide");
  582. messageSends: ["="]
  583. }),
  584. $globals.InterestedInEqual);
  585. $core.addClass("AxonOff", $globals.Error, [], "Axon");
  586. //>>excludeStart("ide", pragmas.excludeIdeData);
  587. $globals.AxonOff.comment="Signal me from the subscription block to unsubscribe it.";
  588. //>>excludeEnd("ide");
  589. $core.addClass("AxonizedObject", $globals.Object, ["axon"], "Axon");
  590. //>>excludeStart("ide", pragmas.excludeIdeData);
  591. $globals.AxonizedObject.comment="I am base class for object using Axon changed:\x0afor event / change logistics,\x0a\x0aSet Axon instance with `axon:` and then use\x0a`self changed: anAspect` to trigger axon's `changed:`.";
  592. //>>excludeEnd("ide");
  593. $core.addMethod(
  594. $core.method({
  595. selector: "axon",
  596. protocol: "accessing",
  597. fn: function (){
  598. var self=this,$self=this;
  599. return $self["@axon"];
  600. },
  601. //>>excludeStart("ide", pragmas.excludeIdeData);
  602. args: [],
  603. source: "axon\x0a\x09^ axon",
  604. referencedClasses: [],
  605. //>>excludeEnd("ide");
  606. messageSends: []
  607. }),
  608. $globals.AxonizedObject);
  609. $core.addMethod(
  610. $core.method({
  611. selector: "axon:",
  612. protocol: "accessing",
  613. fn: function (anAxon){
  614. var self=this,$self=this;
  615. $self["@axon"]=anAxon;
  616. return self;
  617. },
  618. //>>excludeStart("ide", pragmas.excludeIdeData);
  619. args: ["anAxon"],
  620. source: "axon: anAxon\x0a\x09axon := anAxon",
  621. referencedClasses: [],
  622. //>>excludeEnd("ide");
  623. messageSends: []
  624. }),
  625. $globals.AxonizedObject);
  626. $core.addMethod(
  627. $core.method({
  628. selector: "changed:",
  629. protocol: "action",
  630. fn: function (anAspect){
  631. var self=this,$self=this;
  632. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  633. return $core.withContext(function($ctx1) {
  634. //>>excludeEnd("ctx");
  635. $recv($self._axon())._changed_(anAspect);
  636. return self;
  637. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  638. }, function($ctx1) {$ctx1.fill(self,"changed:",{anAspect:anAspect},$globals.AxonizedObject)});
  639. //>>excludeEnd("ctx");
  640. },
  641. //>>excludeStart("ide", pragmas.excludeIdeData);
  642. args: ["anAspect"],
  643. source: "changed: anAspect\x0a\x09self axon changed: anAspect",
  644. referencedClasses: [],
  645. //>>excludeEnd("ide");
  646. messageSends: ["changed:", "axon"]
  647. }),
  648. $globals.AxonizedObject);
  649. $core.addMethod(
  650. $core.method({
  651. selector: "registeredAxon",
  652. protocol: "*Axon",
  653. fn: function (){
  654. var self=this,$self=this;
  655. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  656. return $core.withContext(function($ctx1) {
  657. //>>excludeEnd("ctx");
  658. return self.$axon$;
  659. return self;
  660. //>>excludeStart("ctx", pragmas.excludeDebugContexts);
  661. }, function($ctx1) {$ctx1.fill(self,"registeredAxon",{},$globals.Object)});
  662. //>>excludeEnd("ctx");
  663. },
  664. //>>excludeStart("ide", pragmas.excludeIdeData);
  665. args: [],
  666. source: "registeredAxon\x0a<inlineJS: 'return self.$axon$'>",
  667. referencedClasses: [],
  668. //>>excludeEnd("ide");
  669. messageSends: []
  670. }),
  671. $globals.Object);
  672. });