Method WaitForPendingChanges

db/changes.go:1242–1249

WaitForPendingChanges blocks until the change-cache has caught up with the latest writes to the database.

(ctx context.Context)

// WaitForPendingChanges blocks until the change-cache has caught up with the latest writes to the database.
func (c *DatabaseCollection) WaitForPendingChanges(ctx context.Context) error {
	lastSequence, err := c.LastSequence(ctx)
	if err != nil {
		return err
	}
	base.DebugfCtx(ctx, base.KeyChanges, "Waiting for sequence: %d", lastSequence)
	return c.changeCache().waitForSequence(ctx, lastSequence, base.DefaultWaitForSequence)
}

// Late Sequence Feed
// Manages the changes feed interaction with a channels cache's set of late-arriving entries