QueueMetrics

public protocol QueueMetrics

A 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>

    Parameters

    processorId

    The id of the processor to get the queue size for.