Fix pending logs

Author: itsmepetrov

lib/log-stream.js

@@ -33,15 +33,18 @@ class LogStream extends Readable {
     };
 
     let next = (_err, _data) => {
+      this.pending = false;
       setTimeout(this._read.bind(this), this.options.durationBetweenPolls);
     };
 
-    this.pending = false;
     this.cloudwatchlogs.getLogEvents(params)
       .then((data) => {
-        if (data && data.events.length > 0) {
+        if (data) {
+          if (!this.logsReceived) {
+            this.logsReceived = data.events.length > 0
+          }
+
           this.nextToken = data.nextForwardToken;
-          this.logsReceived = true;
           data.events.forEach((event) => this.eventBuffer.push(event));
         }