QueueMetrics

A utility providing some basic insight into the number of queued events for each processor.

Functions

Returns an observable that will receive the current number of events queued for the given processorId, that are not already in-flight.