Function waitForCompaction

db/channel_cache_test.go:520–529

(cache *channelCacheImpl)

}

func waitForCompaction(cache *channelCacheImpl) (compactionComplete bool) {
	for i := 0; i <= 10; i++ {
		if cache.compactRunning.IsTrue() {
			time.Sleep(100 * time.Millisecond)
		} else {
			return true
		}
	}
	return false
}

// Used for singleChannelCache testing with non-shared testQueryHandler
func testQueryHandlerFactory(collectionID uint32) (ChannelQueryHandler, error) {