- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewJSONFramedReader (0.22 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/framer/framer_test.go
if n, err := r.Read(buf); err != io.EOF && n != 0 { t.Fatalf("unexpected: %v %d", err, n) } } func TestJSONFrameReader(t *testing.T) { b := bytes.NewBufferString("{\"test\":true}\n1\n[\"a\"]") r := NewJSONFramedReader(io.NopCloser(b)) buf := make([]byte, 20) if n, err := r.Read(buf); err != nil || n != 13 || string(buf[:n]) != `{"test":true}` { t.Fatalf("unexpected: %v %d %q", err, n, buf) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 13:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/framer/framer.go
r io.ReadCloser decoder *json.Decoder remaining []byte } // NewJSONFramedReader returns an io.Reader that will decode individual JSON objects off // of a wire. // // The boundaries between each frame are valid JSON objects. A JSON parsing error will terminate // the read. func NewJSONFramedReader(r io.ReadCloser) io.ReadCloser { return &jsonFrameReader{ r: r,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 13:33:12 UTC 2024 - 4.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/json/json.go
} // NewFrameReader implements stream framing for this serializer func (jsonFramer) NewFrameReader(r io.ReadCloser) io.ReadCloser { // we need to extract the JSON chunks of data to pass to Decode() return framer.NewJSONFramedReader(r) } // YAMLFramer is the default JSON framing behavior, with newlines delimiting individual objects. var YAMLFramer = yamlFramer{} type yamlFramer struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 25 16:08:07 UTC 2022 - 12K bytes - Viewed (0)