Merge pull request #2826 from jakemcdermott/fix-2818

fix handling for potentially missed events on initialization
This commit is contained in:
Jake McDermott 2018-08-13 13:40:20 -04:00 committed by GitHub
commit d8e890b651
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -363,9 +363,9 @@ function startListening () {
function handleJobEvent (data) {
streaming = streaming || resource.events
.getRange([Math.max(1, data.counter - 50), data.counter + 50])
.getRange([Math.max(0, data.counter - 50), data.counter + 50])
.then(results => {
results = results.concat(data);
results.push(data);
const counters = results.map(({ counter }) => counter);
const min = Math.min(...counters);
@ -383,7 +383,7 @@ function handleJobEvent (data) {
results = results.filter(({ counter }) => counter > maxMissing);
}
stream.setMissingCounterThreshold(max + 1);
stream.setMissingCounterThreshold(max);
results.forEach(item => {
stream.pushJobEvent(item);
status.pushJobEvent(item);