WaitForSequenceNotSkipped blocks until the given sequence has been received or skipped by the change cache.
(ctx context.Context, sequence uint64)
| 1228 | |
| 1229 | // WaitForSequenceNotSkipped blocks until the given sequence has been received or skipped by the change cache. |
| 1230 | func (c *DatabaseCollection) WaitForSequence(ctx context.Context, sequence uint64) (err error) { |
| 1231 | base.DebugfCtx(ctx, base.KeyChanges, "Waiting for sequence: %d", sequence) |
| 1232 | return c.changeCache().waitForSequence(ctx, sequence, base.DefaultWaitForSequence) |
| 1233 | } |
| 1234 | |
| 1235 | // WaitForSequenceNotSkipped blocks until the given sequence has been received by the change cache without being skipped. |
| 1236 | func (c *DatabaseCollection) WaitForSequenceNotSkipped(ctx context.Context, sequence uint64) (err error) { |
nothing calls this directly
no test coverage detected