日期:2014-05-16 浏览次数:20315 次
// file: src/common/channel.js define("cordova/channel", function(require, exports, module) { var utils = require('cordova/utils'), nextGuid = 1; // ①事件通道的构造函数 var Channel = function(type, sticky) { // 通道名称 this.type = type; // 通道上的所有事件处理函数Map(索引为guid) this.handlers = {}; // 通道的状态(0:非sticky, 1:sticky但未调用, 2:sticky已调用) this.state = sticky ? 1 : 0; // 对于sticky事件通道备份传给fire()的参数 this.fireArgs = null; // 当前通道上的事件处理函数的个数 this.numHandlers = 0; // 订阅第一个事件或者取消订阅最后一个事件时调用自定义的处理 this.onHasSubscribersChange = null; }, // ②事件通道外部接口 channel = { // 把指定的函数h订阅到c的各个通道上,保证h在每个通道的最后被执行 join: function(h, c) { var len = c.length, i = len, f = function() { if (!(--i)) h(); }; // 把事件处理函数h订阅到c的各个事件通道上 for (var j=0; j<len; j++) { // 必须是sticky事件通道 if (c[j].state === 0) { throw Error('Can only use join with sticky channels.'); } c[j].subscribe(f); } // 执行h if (!len) h(); }, // 创建事件通道 create: function(type) { return channel[type] = new Channel(type, false); }, // 创建sticky事件通道 createSticky: function(type) { return channel[type] = new Channel(type, true); }, // 保存deviceready事件之前要调用的事件 deviceReadyChannelsArray: [], deviceReadyChannelsMap: {}, // 设置deviceready事件之前必须要完成的事件 waitForInitialization: function(feature) { if (feature) { var c = channel[feature] || this.createSticky(feature); this.deviceReadyChannelsMap[feature] = c; this.deviceReadyChannelsArray.push(c); } }, // 以前版本的代码,现在好像没有用! initializationComplete: function(feature) { var c = this.deviceReadyChannelsMap[feature]; if (c) { c.fire(); } } }; // 这个应该放入utils里,就是一个函数的判断 function forceFunction(f) { if (typeof f != 'function') throw "Function required as first argument!"; } // ③修改函数原型共享实例方法----------------------- // 向事件通道订阅事件处理函数(subscribe部分) // f:事件处理函数 c:事件的上下文(可省略) Channel.prototype.subscribe = function(f, c) { // 事件处理函数校验 forceFunction(f); // 如果是被订阅过的sticky事件,就直接调用。 if (this.state == 2) { f.apply(c || this, this.fireArgs); return; } var func = f, guid = f.observer_guid; // 如果事件有上下文,要先把事件函数包装一下带上上下文 if (typeof c == "object") { func = utils.close(c, f); } // 自增长的ID if (!guid) { guid = '' + nextGuid++; } // 把自增长的ID反向设置给函数,以后撤消订阅或内部查找用 func.observer_guid = guid; f.observer_guid = guid; // 判断该guid索引的事件处理函数是否存在(保证订阅一次) if (!this.handlers[guid]) { // 订阅到该通道上(索引为guid) this.handlers[guid] = func; // 通道上的事件处理函数的个数增1 this.numHandlers++; if (this.numHandlers == 1) { // 订阅第一个事件时调用自定义的处理(比如:第一次按下返回按钮提示“再按一次...”) this.onHasSubscribersChange && this.onHasSubscribersChange(); } } }; // 撤消订阅通道上的某个函数(guid) Channel.prototype.unsubscribe = function(f) { // 事件处理函数校验 forceFunction(f); // 事件处理函数的guid索引 var guid = f.observer_guid, // 事件处理函数 handler = this.handlers[guid]; if (handler) { // 从该通道上撤消订阅(索引为guid) delete this.handlers[guid]; // 通道上的事件处理函数的个数减1 this.numHandlers--; if (this.numHandlers ===