@@ -50,36 +50,37 @@ func TestDecoder(t *testing.T) {
50
50
decoder := restclientwatch .NewDecoder (streaming .NewDecoder (out , getDecoder ()), getDecoder ())
51
51
expect := & v1.Pod {ObjectMeta : metav1.ObjectMeta {Name : "foo" }}
52
52
encoder := json .NewEncoder (in )
53
- go func (eventType interface {}) {
53
+ eType := eventType
54
+ go func () {
54
55
data , err := runtime .Encode (scheme .Codecs .LegacyCodec (v1 .SchemeGroupVersion ), expect )
55
56
if err != nil {
56
57
t .Fatalf ("Unexpected error %v" , err )
57
58
}
58
59
event := metav1.WatchEvent {
59
- Type : string (eventType ),
60
+ Type : string (eType ),
60
61
Object : runtime.RawExtension {Raw : json .RawMessage (data )},
61
62
}
62
63
if err := encoder .Encode (& event ); err != nil {
63
64
t .Errorf ("Unexpected error %v" , err )
64
65
}
65
66
in .Close ()
66
- }(eventType )
67
+ }()
67
68
68
69
done := make (chan struct {})
69
- go func (eventType interface {} ) {
70
+ go func () {
70
71
action , got , err := decoder .Decode ()
71
72
if err != nil {
72
73
t .Fatalf ("Unexpected error %v" , err )
73
74
}
74
- if e , a := eventType , action ; e != a {
75
+ if e , a := eType , action ; e != a {
75
76
t .Errorf ("Expected %v, got %v" , e , a )
76
77
}
77
78
if e , a := expect , got ; ! apiequality .Semantic .DeepDerivative (e , a ) {
78
79
t .Errorf ("Expected %v, got %v" , e , a )
79
80
}
80
81
t .Logf ("Exited read" )
81
82
close (done )
82
- }(eventType )
83
+ }()
83
84
<- done
84
85
85
86
done = make (chan struct {})
0 commit comments