QueueMetrics Protocol Reference
public protocol QueueMetricsA utility providing some basic insight into the number of queued events for each processor.
-
Returns an observable that will receive the current number of events queued for the given
processorId, that are not already in-flight.Declaration
Swift
func onQueueSizePendingDispatch(for processorId: String) -> Observable<Int>Parameter Description processorIdThe id of the processor to get the queue size for.