rancher/norman
1
0
Fork 0
mirror of https://github.com/rancher/norman.git synced 2025-09-26 15:18:06 +00:00
Code Issues Releases Wiki Activity

Fallback to custom decoder

Browse Source
This commit is contained in:
Darren Shepherd
2018-07-31 16:30:59 -07:00
parent 5a8ca5f1e5
commit 9620967ad5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
store/proxy/proxy_store.go
View File

@@ -241,8 +241,8 @@ func (s *Store) realWatch(apiContext *types.APIContext, schema *types.Schema, op
} }
framer := json.Framer.NewFrameReader(body) framer := json.Framer.NewFrameReader(body)
decoder := streaming.NewDecoder(framer, unstructured.UnstructuredJSONScheme) decoder := streaming.NewDecoder(framer, &unstructuredDecoder{})
watcher := watch.NewStreamWatcher(restclientwatch.NewDecoder(decoder, unstructured.UnstructuredJSONScheme)) watcher := watch.NewStreamWatcher(restclientwatch.NewDecoder(decoder, &unstructuredDecoder{}))
go func() { go func() {
<-apiContext.Request.Context().Done() <-apiContext.Request.Context().Done()