(payload []byte)
| 125 | } |
| 126 | |
| 127 | func (q *queue) enqueue(payload []byte) { |
| 128 | now := time.Now() |
| 129 | |
| 130 | q.mu.Lock() |
| 131 | defer q.mu.Unlock() |
| 132 | |
| 133 | q.pruneLocked(now) |
| 134 | q.items = append(q.items, queueItem{ |
| 135 | enqueuedAt: now, |
| 136 | payload: append([]byte(nil), payload...), |
| 137 | }) |
| 138 | q.maybeCompactLocked() |
| 139 | } |
| 140 | |
| 141 | func (q *queue) publishToSubscribers(payload []byte) bool { |
| 142 | q.mu.Lock() |
no test coverage detected