delta-counter

Count average events per second in a timespan. Just like adding a tally counter to setInterval().

Example/Concept

import * as Mqtt from 'mqtt'
import { DeltaCounter } from 'delta-counter'

const client = Mqtt.connect()
client.on('connect', () => {
    client.subscribe('#')
}

const intervalSec = 5
const dc = new DeltaCounter(intervalSec, (eventsPerSecond) => {
    console.log("Average number of messages per second: "+eventsPerSecond)
}).start()

client.on('message', () => dc.tick())