From 762b2c625cfdc7b679325a284c42b7920940a6b7 Mon Sep 17 00:00:00 2001 From: fanmin shi Date: Thu, 8 Jun 2017 12:11:06 -0700 Subject: [PATCH] clientv3: change watchGrpcStream Close() to close() private struct shouldn't have public method. --- clientv3/watch.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/clientv3/watch.go b/clientv3/watch.go index a707f7449..283c03444 100644 --- a/clientv3/watch.go +++ b/clientv3/watch.go @@ -317,14 +317,14 @@ func (w *watcher) Close() (err error) { w.streams = nil w.mu.Unlock() for _, wgs := range streams { - if werr := wgs.Close(); werr != nil { + if werr := wgs.close(); werr != nil { err = werr } } return err } -func (w *watchGrpcStream) Close() (err error) { +func (w *watchGrpcStream) close() (err error) { w.cancel() <-w.donec select {