summaryrefslogtreecommitdiffstats
path: root/js/service/Publisher.js
diff options
context:
space:
mode:
authorBernhard Posselt <dev@bernhard-posselt.com>2014-05-21 23:43:28 +0200
committerBernhard Posselt <dev@bernhard-posselt.com>2014-05-21 23:43:28 +0200
commit0fa67552247b2d29a6ca438c2605b8db2bbdbab7 (patch)
tree8109135e2fc141a324e8f21c66243ee4277b3b7c /js/service/Publisher.js
parentd3a774b2bd79654360a3ef12618102abf85a2ce3 (diff)
es6 all the things
Diffstat (limited to 'js/service/Publisher.js')
-rw-r--r--js/service/Publisher.js28
1 files changed, 11 insertions, 17 deletions
diff --git a/js/service/Publisher.js b/js/service/Publisher.js
index 784b2fff6..b6ea722ce 100644
--- a/js/service/Publisher.js
+++ b/js/service/Publisher.js
@@ -10,31 +10,25 @@
app.service('Publisher', function () {
'use strict';
- var self = this;
this.channels = {};
- this.subscribe = function (object) {
+ this.subscribe = (obj) => {
return {
- toChannels: function () {
- var counter,
- channel;
- for (counter = 0; counter < arguments.length; counter += 1) {
- channel = arguments[counter];
- self.channels[channel] = self.channels[channel] || [];
- self.channels[channel].push(object);
+ toChannels: (...channels) => {
+ for (let channel of channels) {
+ this.channels[channel] = this.channels[channel] || [];
+ this.channels[channel].push(obj);
}
}
};
- };
- this.publishAll = function (data) {
- var channel,
- counter;
+ };
- for (channel in data) {
- if (data.hasOwnProperty(channel) && this.channels[channel] !== undefined) {
- for (counter = 0; counter < this.channels[channel].length; counter += 1) {
- this.channels[channel][counter].receive(data[channel], channel);
+ this.publishAll = (data) => {
+ for (let channel in data) {
+ if (this.channels[channel] !== undefined) {
+ for (let listener of this.channels[channel]) {
+ listener.receive(data[channel], channel);
}
}
}