Wait for sequence to be buffered by the channel cache
(seq uint64)
| 611 | |
| 612 | // Wait for sequence to be buffered by the channel cache |
| 613 | func (rt *RestTester) WaitForSequence(seq uint64) { |
| 614 | collection, ctx := rt.GetSingleTestDatabaseCollection() |
| 615 | require.NoError(rt.TB(), collection.WaitForSequence(ctx, seq)) |
| 616 | } |
| 617 | |
| 618 | func (rt *RestTester) WaitForPendingChanges() { |
| 619 | ctx := rt.Context() |