From be961bda71c36770e6355c562180486d8cc896fc Mon Sep 17 00:00:00 2001 From: Gaurav Singh Date: Sun, 26 Apr 2020 11:06:32 -0400 Subject: [PATCH] goroutine: Convert eventType to interface{} Kubernetes-commit: e3dde36e1410b4c9b49648378b2dea1612f612fb --- rest/watch/decoder_test.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/rest/watch/decoder_test.go b/rest/watch/decoder_test.go index 0bda7748..493434ec 100644 --- a/rest/watch/decoder_test.go +++ b/rest/watch/decoder_test.go @@ -48,10 +48,9 @@ func TestDecoder(t *testing.T) { out, in := io.Pipe() decoder := restclientwatch.NewDecoder(streaming.NewDecoder(out, getDecoder()), getDecoder()) - eventType := eventType expect := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}} encoder := json.NewEncoder(in) - go func() { + go func(eventType interface{}) { data, err := runtime.Encode(scheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), expect) if err != nil { t.Fatalf("Unexpected error %v", err) @@ -64,10 +63,10 @@ func TestDecoder(t *testing.T) { t.Errorf("Unexpected error %v", err) } in.Close() - }() + }(eventType) done := make(chan struct{}) - go func() { + go func(eventType interface{}) { action, got, err := decoder.Decode() if err != nil { t.Fatalf("Unexpected error %v", err) @@ -80,7 +79,7 @@ func TestDecoder(t *testing.T) { } t.Logf("Exited read") close(done) - }() + }(eventType) <-done done = make(chan struct{})