File tree Expand file tree Collapse file tree 1 file changed +4
-5
lines changed
staging/src/k8s.io/client-go/rest/watch Expand file tree Collapse file tree 1 file changed +4
-5
lines changed Original file line number Diff line number Diff line change @@ -48,10 +48,9 @@ func TestDecoder(t *testing.T) {
48
48
out , in := io .Pipe ()
49
49
50
50
decoder := restclientwatch .NewDecoder (streaming .NewDecoder (out , getDecoder ()), getDecoder ())
51
- eventType := eventType
52
51
expect := & v1.Pod {ObjectMeta : metav1.ObjectMeta {Name : "foo" }}
53
52
encoder := json .NewEncoder (in )
54
- go func () {
53
+ go func (eventType interface {} ) {
55
54
data , err := runtime .Encode (scheme .Codecs .LegacyCodec (v1 .SchemeGroupVersion ), expect )
56
55
if err != nil {
57
56
t .Fatalf ("Unexpected error %v" , err )
@@ -64,10 +63,10 @@ func TestDecoder(t *testing.T) {
64
63
t .Errorf ("Unexpected error %v" , err )
65
64
}
66
65
in .Close ()
67
- }()
66
+ }(eventType )
68
67
69
68
done := make (chan struct {})
70
- go func () {
69
+ go func (eventType interface {} ) {
71
70
action , got , err := decoder .Decode ()
72
71
if err != nil {
73
72
t .Fatalf ("Unexpected error %v" , err )
@@ -80,7 +79,7 @@ func TestDecoder(t *testing.T) {
80
79
}
81
80
t .Logf ("Exited read" )
82
81
close (done )
83
- }()
82
+ }(eventType )
84
83
<- done
85
84
86
85
done = make (chan struct {})
You can’t perform that action at this time.
0 commit comments