Return true if an Add/Update/Delete/AddIfNotPresent are called first, or an Update called first but the first batch of items inserted by Replace() has been popped
()
| 163 | // Return true if an Add/Update/Delete/AddIfNotPresent are called first, |
| 164 | // or an Update called first but the first batch of items inserted by Replace() has been popped |
| 165 | func (f *DeltaFIFO) HasSynced() bool { |
| 166 | f.lock.Lock() |
| 167 | defer f.lock.Unlock() |
| 168 | return f.populated && f.initialPopulationCount == 0 |
| 169 | } |
| 170 | |
| 171 | // Add inserts an item, and puts it in the queue. The item is only enqueued |
| 172 | // if it doesn't already exist in the set. |
no outgoing calls