Fetch current item
()
| 156 | |
| 157 | // Fetch current item |
| 158 | func (q *QueueIterator) Fetch() (interface{}, errors.Error) { |
| 159 | node := q.queue.Pull() |
| 160 | if node == nil { |
| 161 | return nil, nil |
| 162 | } else { |
| 163 | return node.Data(), nil |
| 164 | } |
| 165 | } |
| 166 | |
| 167 | // Push a data into queue |
| 168 | func (q *QueueIterator) Push(data interface{}) { |