I am using RxJs to count how many packets arrive in a particular time window. My code basically looks l