- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewJSONFramedReader (0.27 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)