debug

watch/source_test.go

@@ -30,11 +30,11 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
-// func TestSource1(t *testing.T) {
-// 	for i := 0; i < 1; i++ {
-// 		testSource(t, 30, 25, 20)
-// 	}
-// }
+func TestSource1(t *testing.T) {
+	for i := 0; i < 1; i++ {
+		testSource(t, 30, 25, 20)
+	}
+}
 
 func TestSource2(t *testing.T) {
 	for i := 0; i < 10; i++ {
@@ -84,12 +84,15 @@ func testSource(t *testing.T, errAfter int32, closeAfter int32, watchNum int) {
 		wg.Add(1)
 		_, w, err := s.Watch()
 		assert.NoError(t, err)
+		assert.NotNil(t, w)
+		c := w.C()
+		assert.NotNil(t, c)
 
 		i := i
 		go func() {
 			var v interface{}
 			count := 0
-			for range w.C() {
+			for range c {
 				if v != nil {
 					assert.True(t, w.Get().(int32) >= v.(int32))
 				}