Merge pull request #3 from hao4/fix-error

Handle InvalidSequenceTokenException
pling · Feb 11, 2020 · 4e8ccdb · 4e8ccdb
2 parents 269eaf3 + 2ad7b1d
commit 4e8ccdb
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/index.js b/index.js
@@ -151,6 +151,9 @@ module.exports = class CloudWatchStream extends EventEmitter {
                 if (error) {
                     if (error.retryable && attempts++ < 5) {
                         setTimeout(postLogEvents, 100);
+                    } else if (error.code === 'InvalidSequenceTokenException') {
+                        delete that._sequenceToken;
+                        that._getSequenceToken(postLogEvents)
                     } else {
                         callback(error);
                     }