metrics.PollSuccessPerTaskQueueCounter.With(tm.metricsHandler).Record(1)
return task, false, nil
metrics.PollSuccessWithSyncPerTaskQueueCounter.With(tm.metricsHandler).Record(1)
metrics.PollSuccessPerTaskQueueCounter.With(tm.metricsHandler).Record(1)
return task, false, nil
case token := <-tm.fwdrPollReqTokenC():
// Arrange to cancel this request if closeC is closed