There was an error while loading. Please reload this page.
1 parent c6357fd commit 253d867Copy full SHA for 253d867
1 file changed
pkg/api/soc_test.go
@@ -95,6 +95,12 @@ func TestSOC(t *testing.T) {
95
}),
96
)
97
98
+ // Wait for the chanStorer drain goroutine to process the chunk and invoke
99
+ // the subscriber (which stores it in mockStorer) before issuing GETs.
100
+ if err := spinlock.Wait(2*time.Second, func() bool { return chanStore.Has(s.Address()) }); err != nil {
101
+ t.Fatal("timed out waiting for chunk to be stored:", err)
102
+ }
103
+
104
// try to fetch the same chunk
105
t.Run("chunks fetch", func(t *testing.T) {
106
rsrc := fmt.Sprintf("/chunks/%s", s.Address().String())
0 commit comments