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{})