Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 589 for Decoder (0.09 sec)

  1. android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java

              // otherwise try to presize a StringBuilder
              // it is kind of lame that we need to construct a decoder to access this value.
              // if this is a concern we could add special cases for some known charsets (like utf8)
              // or we could avoid inputstreamreader and use the decoder api directly
              // TODO(lukes): in a real implementation we would need to handle overflow conditions
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 10 19:45:10 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  2. internal/s3select/jstream/README.md

    we can choose to extract and act only the objects within the top-level array:
    ```go
    f, _ := os.Open("input.json")
    decoder := jstream.NewDecoder(f, 1) // extract JSON values at a depth level of 1
    for mv := range decoder.Stream() {
      fmt.Printf("%v\n ", mv.Value)
    }
    ```
    
    output:
    ```
    map[desc:RGB colors:[red green blue]]
    map[desc:CMYK colors:[cyan magenta yellow black]]
    ```
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. internal/s3select/parquet/args.go

    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  4. internal/s3select/simdj/reader.go

    		readCloser: &safeCloser{r: io.Reader(readCloser)},
    		decoded:    make(chan simdjson.Object, 1000),
    		input:      make(chan simdjson.Stream, 2),
    		exitReader: make(chan struct{}),
    	}
    	r.onReaderExit = func() {
    		close(r.decoded)
    		readCloser.Close()
    		for range r.input {
    			// Read until EOF trickles through.
    			// Otherwise, we risk the decoder hanging.
    		}
    		r.readerWg.Done()
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  5. internal/s3select/json/args.go

    	unmarshaled bool
    }
    
    // IsEmpty - returns whether reader args is empty or not.
    func (args *ReaderArgs) IsEmpty() bool {
    	return !args.unmarshaled
    }
    
    // UnmarshalXML - decodes XML data.
    func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type subReaderArgs ReaderArgs
    	parsedArgs := subReaderArgs{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 2.7K bytes
    - Viewed (0)
  6. internal/bucket/replication/rule.go

    		return errDeleteReplicationMissing
    	}
    	if d.Status != Disabled && d.Status != Enabled {
    		return errInvalidDeleteReplicationStatus
    	}
    	return nil
    }
    
    // UnmarshalXML - decodes XML data.
    func (d *DeleteReplication) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) (err error) {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type deleteReplication DeleteReplication
    	drep := deleteReplication{}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 24 23:22:20 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackRoundTripTest.kt

    import org.junit.jupiter.params.provider.ArgumentsSource
    
    /**
     * Tests for round-tripping headers through hpack.
     *
     * TODO: update hpack-test-case with the output of our encoder.
     * This test will hide complementary bugs in the encoder and decoder,
     * We should test that the encoder is producing responses that are
     */
    class HpackRoundTripTest : HpackDecodeTestBase() {
      internal class StoriesTestProvider : SimpleProvider() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/tag.go

    	errDuplicatedXMLTag = Errorf("duplicated XML Tag")
    	errUnknownXMLTag    = Errorf("unknown XML Tag")
    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  9. internal/bucket/object/lock/lock.go

    const (
    	// This tested by using `mc lock` command
    	maximumRetentionDays  = 36500
    	maximumRetentionYears = 100
    )
    
    // UnmarshalXML - decodes XML data.
    func (dr *DefaultRetention) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    	// Make subtype to avoid recursive UnmarshalXML().
    	type defaultRetention DefaultRetention
    	retention := defaultRetention{}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. internal/bucket/lifecycle/delmarker-expiration.go

    // Used to detect if lifecycle.Rule contained a DelMarkerExpiration element.
    func (de DelMarkerExpiration) Empty() bool {
    	return de.Days == 0
    }
    
    // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
    func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error {
    	type delMarkerExpiration DelMarkerExpiration
    	var dexp delMarkerExpiration
    	err := dec.DecodeElement(&dexp, &start)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 2.3K bytes
    - Viewed (0)
Back to top