Spaces:
Runtime error
Runtime error
File size: 1,888 Bytes
8df6da4 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 |
import { dbg_assert } from "./log.js";
export var Bus = {};
/** @constructor */
export function BusConnector()
{
this.listeners = {};
this.pair = undefined;
}
/**
* @param {string} name
* @param {function(?)} fn
* @param {Object} this_value
*/
BusConnector.prototype.register = function(name, fn, this_value)
{
var listeners = this.listeners[name];
if(listeners === undefined)
{
listeners = this.listeners[name] = [];
}
listeners.push({
fn: fn,
this_value: this_value,
});
};
/**
* Unregister one message with the given name and callback
*
* @param {string} name
* @param {function(?)} fn
*/
BusConnector.prototype.unregister = function(name, fn)
{
var listeners = this.listeners[name];
if(listeners === undefined)
{
return;
}
this.listeners[name] = listeners.filter(function(l)
{
return l.fn !== fn;
});
};
/**
* Send ("emit") a message
*
* @param {string} name
* @param {*=} value
* @param {*=} unused_transfer
*/
BusConnector.prototype.send = function(name, value, unused_transfer)
{
if(!this.pair)
{
return;
}
var listeners = this.pair.listeners[name];
if(listeners === undefined)
{
return;
}
for(var i = 0; i < listeners.length; i++)
{
var listener = listeners[i];
listener.fn.call(listener.this_value, value);
}
};
/**
* Send a message, guaranteeing that it is received asynchronously
*
* @param {string} name
* @param {Object=} value
*/
BusConnector.prototype.send_async = function(name, value)
{
dbg_assert(arguments.length === 1 || arguments.length === 2);
setTimeout(this.send.bind(this, name, value), 0);
};
Bus.create = function()
{
var c0 = new BusConnector();
var c1 = new BusConnector();
c0.pair = c1;
c1.pair = c0;
return [c0, c1];
};
|