pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-06-15 11:51:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Styles

Browse Source
This commit is contained in:
maciejhirsz
2018-07-05 18:29:19 +02:00
parent 01da7dfc47
commit 8bec72be35
7 changed files with 43 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/backend/src/aggregator.ts
+5 -5
View File
@@ -1,11 +1,11 @@
import * as EventEmitter from 'events';
import Node from './node';
import Feed from './feed';
import { timestamp, Types, IdSet, FeedMessage } from '@dotstats/common';
import { timestamp, Types, FeedMessage } from '@dotstats/common';
export default class Aggregator extends EventEmitter {
private nodes = new IdSet<Types.NodeId, Node>();
private feeds = new IdSet<Types.FeedId, Feed>();
private nodes = new Set<Node>();
private feeds = new Set<Feed>();
private messages: Array<FeedMessage.Message> = [];
public height = 0 as Types.BlockNumber;
@@ -24,7 +24,7 @@ export default class Aggregator extends EventEmitter {
node.once('disconnect', () => {
node.removeAllListeners();
this.nodes.remove(node);
this.nodes.delete(node);
this.broadcast(Feed.removedNode(node));
});
@@ -44,7 +44,7 @@ export default class Aggregator extends EventEmitter {
feed.sendMessages(messages);
feed.once('disconnect', () => {
this.feeds.remove(feed);
this.feeds.delete(feed);
});
}