firehoseio/firehose

Error occurs when connection is re-established

Closed this issue · 1 comments

TypeError: 'undefined' is not a function (evaluating 'this.transport.getLastMessageSequence()')

Consumer.prototype._upgradeTransport = function(ws) {
this.transport.stop();
=> ws.sendStartingMessageSequence(this.transport.getLastMessageSequence());
return this.transport = ws;
};

This should be fixed now...