(data []byte, len int)
| 156 | } |
| 157 | |
| 158 | func (q *BytesQueue) copy(data []byte, len int) { |
| 159 | q.tail += copy(q.array[q.tail:], data[:len]) |
| 160 | } |
| 161 | |
| 162 | // Pop reads the oldest entry from queue and moves head pointer to the next one |
| 163 | func (q *BytesQueue) Pop() ([]byte, error) { |