refactor: _read should proceed only when res is not undefined or null

Author: kessler

index.js

@@ -11,20 +11,22 @@ class AWSApiReadStream extends Readable {
 	async _read(size) {
 		try {
 			const res = await this._fn(this._nextToken)
-			if (this._isInBufferMode()) {
-				this._buffer.push(res)
-			}
+			if (res) {
+				if (this._isInBufferMode()) {
+					this._buffer.push(res)
+				}
 
-			this.push(res)
+				this.push(res)
 
-			if (res && res.NextToken !== undefined) {
-				this._nextToken = res.NextToken
-				return
-			}
+				if (res.NextToken !== undefined) {
+					this._nextToken = res.NextToken
+					return
+				}
 
-			if (res && res.NextContinuationToken !== undefined) {
-				this._nextToken = res.NextContinuationToken
-				return
+				if (res.NextContinuationToken !== undefined) {
+					this._nextToken = res.NextContinuationToken
+					return
+				}
 			}
 
 			this.push(null)
@@ -33,6 +35,11 @@ class AWSApiReadStream extends Readable {
 		}
 	}
 
+	stop() {
+		this._stop = true
+		this.destroy()
+	}
+
 	static from(fn, { nextToken, options } = {}) {
 		return new AWSApiReadStream(fn, options, nextToken)
 	}