kubernetes/staging/src/k8s.io/client-go/rest/watch/decoder_test.go

// getDecoder mimics how k8s.io/client-go/rest.createSerializers creates a decoder
func getDecoder() runtime.Decoder { … }

func TestDecoder(t *testing.T) { … }

func TestDecoder_SourceClose(t *testing.T) { … }