(onRequest func(r *Request) error)
| 145 | } |
| 146 | |
| 147 | func (c *RequestChan) PopFrontAll(onRequest func(r *Request) error) error { |
| 148 | for { |
| 149 | r, ok := c.PopFront() |
| 150 | if ok { |
| 151 | if err := onRequest(r); err != nil { |
| 152 | return err |
| 153 | } |
| 154 | } else { |
| 155 | return nil |
| 156 | } |
| 157 | } |
| 158 | } |
| 159 | |
| 160 | func (c *RequestChan) PopFrontAllVoid(onRequest func(r *Request)) { |
| 161 | c.PopFrontAll(func(r *Request) error { |
no test coverage detected