Method WaitForSequenceNotSkipped

db/changes.go:1236–1239

WaitForSequenceNotSkipped blocks until the given sequence has been received by the change cache without being skipped.

(ctx context.Context, sequence uint64)

// WaitForSequenceNotSkipped blocks until the given sequence has been received by the change cache without being skipped.
func (c *DatabaseCollection) WaitForSequenceNotSkipped(ctx context.Context, sequence uint64) (err error) {
	base.DebugfCtx(ctx, base.KeyChanges, "Waiting for sequence: %d", sequence)
	return c.changeCache().waitForSequenceNotSkipped(ctx, sequence, base.DefaultWaitForSequence)
}

// WaitForPendingChanges blocks until the change-cache has caught up with the latest writes to the database.
func (c *DatabaseCollection) WaitForPendingChanges(ctx context.Context) error {