()
| 37 | var FIFOClosedError error = errors.New("DeltaFIFO: manipulating with closed queue") |
| 38 | |
| 39 | func (e ErrRequeue) Error() string { |
| 40 | if e.Err == nil { |
| 41 | return "the popped item should be requeued without returning an error" |
| 42 | } |
| 43 | return e.Err.Error() |
| 44 | } |
| 45 | |
| 46 | // Queue is exactly like a Store, but has a Pop() method too. |
| 47 | type Queue interface { |