Function getChanges

db/change_cache_test.go:2848–2859

getChanges is a synchronous convenience function that returns all changes as a simple array. This will fail the test if an error is returned.

(t *testing.T, collection *DatabaseCollectionWithUser, channels base.Set, options ChangesOptions)

// getChanges is a synchronous convenience function that returns all changes as a simple array. This will fail the test if an error is returned.
func getChanges(t *testing.T, collection *DatabaseCollectionWithUser, channels base.Set, options ChangesOptions) []*ChangeEntry {
	require.NotNil(t, options.ChangesCtx)
	feed, err := collection.MultiChangesFeed(options.ChangesCtx, channels, options)

	require.NoError(t, err)
	require.NotNil(t, feed)
	var changes = make([]*ChangeEntry, 0, 50)
	for entry := range feed {
		changes = append(changes, entry)
	}
	return changes
}

func TestBroadcastFrequencyAfterSkippedCompact(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCache)