Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewElementReader (0.1 sec)

  1. internal/s3select/simdj/reader.go

    	// We cannot reuse as we are sending parsed objects elsewhere.
    	simdjson.ParseNDStream(readCloser, r.input, nil)
    	r.readerWg.Add(1)
    	go r.startReader()
    	return &r
    }
    
    // NewElementReader - creates new JSON reader using readCloser.
    func NewElementReader(ch chan simdjson.Object, err *error, args *json.ReaderArgs) *Reader {
    	return &Reader{
    		args:       args,
    		decoded:    ch,
    		err:        err,
    		readCloser: nil,
    	}
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader_amd64_test.go

    	}
    
    	for _, tt := range testCases {
    		t.Run(tt.name, func(t *testing.T) {
    			ref := loadCompressed(t, tt.name)
    
    			var err error
    			dst := make(chan simdjson.Object, 100)
    			dec := NewElementReader(dst, &err, &json.ReaderArgs{ContentType: "json"})
    			pj, err := simdjson.ParseND(ref, nil)
    			if err != nil {
    				t.Fatal(err)
    			}
    			i := pj.Iter()
    			cpy := i
    			b, err := cpy.MarshalJSON()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 3.9K bytes
    - Viewed (0)
Back to top