diff options
author | Bernhard Posselt <dev@bernhard-posselt.com> | 2014-05-21 23:43:28 +0200 |
---|---|---|
committer | Bernhard Posselt <dev@bernhard-posselt.com> | 2014-05-21 23:43:28 +0200 |
commit | 0fa67552247b2d29a6ca438c2605b8db2bbdbab7 (patch) | |
tree | 8109135e2fc141a324e8f21c66243ee4277b3b7c /js/service/Publisher.js | |
parent | d3a774b2bd79654360a3ef12618102abf85a2ce3 (diff) |
es6 all the things
Diffstat (limited to 'js/service/Publisher.js')
-rw-r--r-- | js/service/Publisher.js | 28 |
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); } } } |