use poll interval option

crccheck · Feb 19, 2017 · 404d40b · 404d40b
1 parent 2c598ea
commit 404d40b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -59,5 +59,11 @@ Reader readable stream too!
     const reader = new KinesisStreamReader(client, streamName, options)
     reader.pipe(yourDestinationHere)
 
+### Options
+
+* `interval` Milliseconds between each Kinesis read. Remember there is a low
+  limit of 5 reads / second / shard
+* Any [getShardIterator] param
 
   [Kafka quickstart]: http://kafka.apache.org/documentation.html#quickstart_consume
+  [getShardIterator]: http://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/Kinesis.html#getShardIterator-property
diff --git a/index.js b/index.js
@@ -90,7 +90,7 @@ class KinesisStreamReader extends Readable {
       setTimeout(() => {
         this.readShard(data.NextShardIterator)
         // idleTimeBetweenReadsInMillis  http://docs.aws.amazon.com/streams/latest/dev/kinesis-low-latency.html
-      }, 2000)
+      }, this.interval)
     })
   }