Adding wait for subscribe to complete
@@ -31,7 +31,8 @@ import (
const (
keyCount = 10
v1 = "1.0.0"
- defaultMaxReadDuration = 60 * time.Second
+ defaultMaxReadDuration = 30 * time.Second
+ defaultWaitDuration = 5 * time.Second
)
type TestConfig struct {
@@ -199,6 +200,10 @@ func ConformanceTests(t *testing.T, props map[string]string, store configuration
subscribeIDs = append(subscribeIDs, Id2)
})
+ t.Run("wait", func(t *testing.T) {
+ time.Sleep(defaultWaitDuration)
+ })
+
t.Run("Update Keys/Add new keys", func(t *testing.T) {
//Update existing keys
updatedValues := updateKeyValues(initValues, runID, counter, v1)
