Pop blocks until it has something to process. It returns the object that was process and the result of processing. The PopProcessFunc may return an ErrRequeue{...} to indicate the item should be requeued before releasing the lock on the queue.
(PopProcessFunc)
| 52 | // The PopProcessFunc may return an ErrRequeue{...} to indicate the item |
| 53 | // should be requeued before releasing the lock on the queue. |
| 54 | Pop(PopProcessFunc) (interface{}, error) |
| 55 | |
| 56 | // AddIfNotPresent adds a value previously |
| 57 | // returned by Pop back into the queue as long |
no outgoing calls
no test coverage detected