After multiple trial-n-error, figured the answer to this onNext is invoked asynchronously - I added log statements and confirmed onNext function gets invoked for ALL available events and action doesnt wait for any of event completion.I even forced await like this .subscribe(
async (x) => awai...