Clear nodes on re-subbing (#69)

This commit is contained in:
Maciej Hirsz
2018-09-30 09:43:03 +02:00
committed by GitHub
parent 8b7c620e2e
commit dd379676fd
3 changed files with 6 additions and 3 deletions
+1 -1
View File
@@ -33,8 +33,8 @@ export default class Aggregator {
const chain = this.chains.get(label);
if (chain) {
chain.addFeed(feed);
feed.sendMessage(Feed.subscribedTo(label));
chain.addFeed(feed);
}
});
+1 -1
View File
@@ -8,4 +8,4 @@ import * as FeedMessage from './feed';
export { Types, FeedMessage };
// Increment this if breaking changes were made to types in `feed.ts`
export const VERSION: Types.FeedVersion = 15 as Types.FeedVersion;
export const VERSION: Types.FeedVersion = 16 as Types.FeedVersion;
+4 -1
View File
@@ -281,7 +281,10 @@ export class Connection {
}
case Actions.SubscribedTo: {
this.state = this.update({ subscribed: message.payload });
nodes.clear();
sortedNodes = [];
this.state = this.update({ subscribed: message.payload, nodes, sortedNodes });
continue messages;
}