We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 339b0f0 commit 450daeeCopy full SHA for 450daee
provider/buffered/provider_test.go
@@ -258,16 +258,7 @@ func TestBatchProcessing(t *testing.T) {
258
if err := provider.StartProviding(false, keys[2]); err != nil {
259
t.Fatalf("StartProviding failed: %v", err)
260
}
261
-
262
- // Wait for batch to be triggered (should process all 3 operations in one batch)
263
- // Expect 2 signals: 1 for ProvideOnce (with 2 keys), 1 for StartProviding (with 1 key)
264
- for i := 0; i < 2; i++ {
265
- select {
266
- case <-fake.processed:
267
- case <-time.After(time.Second):
268
- t.Fatalf("Timeout waiting for operation %d to be processed", i+1)
269
- }
270
+ synctest.Wait()
271
272
// Close to ensure all operations are flushed
273
provider.Close()
0 commit comments