Function main

benchmark/diagnostics_channel/publish.js:27–58

({ n, subscribers, checkSubscribers, objSize })

}

function main({ n, subscribers, checkSubscribers, objSize }) {
  const channel = dc.channel('test');
  for (let i = 0; i < subscribers; i++) {
    channel.subscribe(noop);
  }

  const publishWithCheck = () => {
    const data = createObj(objSize);
    bench.start();
    for (let i = 0; i < n; i++) {
      if (channel.hasSubscribers) {
        channel.publish(data);
      }
    }
    bench.end(n);
  };

  const publishWithoutCheck = () => {
    const data = createObj(objSize);
    bench.start();
    for (let i = 0; i < n; i++) {
      channel.publish(data);
    }
    bench.end(n);
  };

  if (checkSubscribers) {
    publishWithCheck();
  } else {
    publishWithoutCheck();
  }
}