Method waitForCacheUpdate

db/changes.go:1207–1222

(ctx context.Context, currentCachedSequence uint64)

}

func (col *DatabaseCollectionWithUser) waitForCacheUpdate(ctx context.Context, currentCachedSequence uint64) (cancelled bool) {
	ticker := time.NewTicker(100 * time.Millisecond)
	defer ticker.Stop()
	for retry := 0; retry <= 50; retry++ {
		select {
		// Check if feed has been terminated regardless of if any changes have happened
		case <-ctx.Done():
			return true
		case <-ticker.C:
			if col.changeCache().getChannelCache().GetHighCacheSequence() != currentCachedSequence {
				return false
			}
		}
	}
	return false
}

// Returns the set of cached log entries for a given channel
func (c *DatabaseCollection) GetChangeLog(ctx context.Context, channel channels.ID, afterSeq uint64) (entries []*LogEntry, err error) {