diff --git a/lib/ddp.js b/lib/ddp.js index 81d61c8..c55c72f 100644 --- a/lib/ddp.js +++ b/lib/ddp.js @@ -115,6 +115,7 @@ export default class DDP extends EventEmitter { this.socket.on('message:in', (message) => { if (message.msg === 'connected') { this.status = 'connected'; + this._lastSessionId = message.session; this.messageQueue.process(); this.emit('connected'); } else if (message.msg === 'ping') { diff --git a/src/Meteor.js b/src/Meteor.js index f3c5663..15a87a2 100644 --- a/src/Meteor.js +++ b/src/Meteor.js @@ -169,6 +169,13 @@ const Meteor = { console.info('Disconnected from DDP server.'); } + // Mark subscriptions as ready=false + for (var i in Data.subscriptions) { + const sub = Data.subscriptions[i]; + sub.ready = false; + sub.readyDeps.changed(); + } + if (!Data.ddp.autoReconnect) return; if (!lastDisconnect || new Date() - lastDisconnect > 3000) {