github/client-go
1
0
Fork 0
mirror of https://github.com/kubernetes/client-go.git synced 2025-06-29 16:36:54 +00:00
Code Issues Projects Releases Wiki Activity

goroutine: Convert eventType to interface{}

Browse Source 
Kubernetes-commit: e3dde36e1410b4c9b49648378b2dea1612f612fb
This commit is contained in:
Gaurav Singh 2020-04-26 11:06:32 -04:00 committed by Kubernetes Publisher
parent f74b86b7ea
commit be961bda71
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
rest/watch/decoder_test.go
View File

@ -48,10 +48,9 @@ func TestDecoder(t *testing.T) {
out, in := io.Pipe() out, in := io.Pipe()
decoder := restclientwatch.NewDecoder(streaming.NewDecoder(out, getDecoder()), getDecoder()) decoder := restclientwatch.NewDecoder(streaming.NewDecoder(out, getDecoder()), getDecoder())
eventType := eventType
expect := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}} expect := &v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}}
encoder := json.NewEncoder(in) encoder := json.NewEncoder(in)
go func() { go func(eventType interface{}) {
data, err := runtime.Encode(scheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), expect) data, err := runtime.Encode(scheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), expect)
if err != nil { if err != nil {
t.Fatalf("Unexpected error %v", err) t.Fatalf("Unexpected error %v", err)
@ -64,10 +63,10 @@ func TestDecoder(t *testing.T) {
t.Errorf("Unexpected error %v", err) t.Errorf("Unexpected error %v", err)
} }
in.Close() in.Close()
}() }(eventType)
done := make(chan struct{}) done := make(chan struct{})
go func() { go func(eventType interface{}) {
action, got, err := decoder.Decode() action, got, err := decoder.Decode()
if err != nil { if err != nil {
t.Fatalf("Unexpected error %v", err) t.Fatalf("Unexpected error %v", err)
@ -80,7 +79,7 @@ func TestDecoder(t *testing.T) {
} }
t.Logf("Exited read") t.Logf("Exited read")
close(done) close(done)
}() }(eventType)
<-done <-done
done = make(chan struct{}) done = make(chan struct{})