Class

example/clear-ddb-table.mjs:45–45

const sleep = (time) => new Promise((resolve) => setTimeout(resolve, time));

class AsyncProcessor {
  constructor(producerFunction, consumerFunction) {
    this.producerFunction = producerFunction;
    this.consumerFunction = consumerFunction;