fix: closed WatchResponse channel when cancel function is called (#779)…

… (#795)
apache · Nov 12, 2020 · 88903fa · 88903fa
1 parent e08f3ab
commit 88903fa
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/api/internal/core/storage/etcd.go b/api/internal/core/storage/etcd.go
@@ -19,9 +19,10 @@ package storage
 import (
 	"context"
 	"fmt"
+	"time"
+
 	"github.com/apisix/manager-api/internal/utils"
 	"go.etcd.io/etcd/clientv3"
-	"time"
 )
 
 var (
@@ -132,6 +133,8 @@ func (s *EtcdV3Storage) Watch(ctx context.Context, key string) <-chan WatchRespo
 			}
 			ch <- output
 		}
+
+		close(ch)
 	}()
 
 	return ch