Consuming the Async Generator with Throttling

throttled-client.js

const {RateLimiter} = require('limiter');

async function main(rate, interval) {
  const rateLimiter = new RateLimiter(rate, interval);
  
  for await (const iter of queryBatches('ExampleTable', {keyConditionExpressoin: {...}, expressionAttributeValues: {...}})) {
    const {ConsumedCapacity} = iter.metadata();
    
    for (const value of iter) {
      // You can use functional-pipelines to reduce or transduce the iterator as needed
      console.log(value);
    }
    
    // Throttling
    await rateLimiter.getTokens(ConsumedCapacity);
  }
}

main(10, 'second')
  .then(result => console.log(result)
  .catch(error => console.error(error);