diff --git a/NetfluxWebsocketSrv.js b/NetfluxWebsocketSrv.js index 03889ee8e..d92510749 100644 --- a/NetfluxWebsocketSrv.js +++ b/NetfluxWebsocketSrv.js @@ -106,6 +106,10 @@ const getHistory = function (ctx, channelName, handler, cb) { } //console.log(messageBuf[startPoint]); } + if (cpCount < 2) { + // no checkpoints. + for (var x = msgBuff2.pop(); x; x = msgBuff2.pop()) { handler(x); } + } cb(); }); };