(id uint64)
| 184 | } |
| 185 | |
| 186 | func (q *queue) unsubscribe(id uint64) { |
| 187 | q.mu.Lock() |
| 188 | subscriber, ok := q.subscribers[id] |
| 189 | if ok { |
| 190 | delete(q.subscribers, id) |
| 191 | } |
| 192 | q.mu.Unlock() |
| 193 | |
| 194 | if ok { |
| 195 | close(subscriber) |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | func (q *queue) popOldest(count int) [][]byte { |
| 200 | now := time.Now() |