From 9620967ad5d6e7abf52872ffe7c55774feb73a52 Mon Sep 17 00:00:00 2001 From: Darren Shepherd Date: Tue, 31 Jul 2018 16:30:59 -0700 Subject: [PATCH] Fallback to custom decoder --- store/proxy/proxy_store.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/store/proxy/proxy_store.go b/store/proxy/proxy_store.go index fb07d3db..7a004b89 100644 --- a/store/proxy/proxy_store.go +++ b/store/proxy/proxy_store.go @@ -241,8 +241,8 @@ func (s *Store) realWatch(apiContext *types.APIContext, schema *types.Schema, op } framer := json.Framer.NewFrameReader(body) - decoder := streaming.NewDecoder(framer, unstructured.UnstructuredJSONScheme) - watcher := watch.NewStreamWatcher(restclientwatch.NewDecoder(decoder, unstructured.UnstructuredJSONScheme)) + decoder := streaming.NewDecoder(framer, &unstructuredDecoder{}) + watcher := watch.NewStreamWatcher(restclientwatch.NewDecoder(decoder, &unstructuredDecoder{})) go func() { <-apiContext.Request.Context().Done()