Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 511 - 520 of 1,019 for readFn (0.05 seconds)

  1. internal/s3select/jstream/errors.go

    type DecoderError struct {
    	msg       string // description of error
    	context   string // additional error context
    	pos       errPos
    	atChar    byte
    	readerErr error // underlying reader error, if any
    }
    
    // ReaderErr returns the underlying error.
    func (e DecoderError) ReaderErr() error { return e.readerErr }
    
    // Error returns a string representation of the error.
    func (e DecoderError) Error() string {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 1.3K bytes
    - Click Count (0)
  2. src/cmd/asm/internal/lex/tokenizer.go

    type Tokenizer struct {
    	tok  ScanToken
    	s    *scanner.Scanner
    	base *src.PosBase
    	line int
    	file *os.File // If non-nil, file descriptor to close.
    }
    
    func NewTokenizer(name string, r io.Reader, file *os.File) *Tokenizer {
    	var s scanner.Scanner
    	s.Init(r)
    	// Newline is like a semicolon; other space characters are fine.
    	s.Whitespace = 1<<'\t' | 1<<'\r' | 1<<' '
    	// Don't skip comments: we need to count newlines.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Aug 04 20:35:21 GMT 2022
    - 3K bytes
    - Click Count (0)
  3. cmd/bucket-lifecycle.go

    	}
    
    	timeTierAction := auditTierActions(ctx, oi.TransitionedObject.Tier, length)
    	reader, err := tgtClient.Get(ctx, oi.TransitionedObject.Name, remoteVersionID(oi.TransitionedObject.VersionID), gopts)
    	if err != nil {
    		return nil, err
    	}
    	closer := func() {
    		timeTierAction(reader.Close())
    	}
    	return fn(reader, h, closer)
    }
    
    // RestoreRequestType represents type of restore.
    type RestoreRequestType string
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  4. src/cmd/asm/internal/lex/stack.go

    // license that can be found in the LICENSE file.
    
    package lex
    
    import (
    	"text/scanner"
    
    	"cmd/internal/src"
    )
    
    // A Stack is a stack of TokenReaders. As the top TokenReader hits EOF,
    // it resumes reading the next one down.
    type Stack struct {
    	tr []TokenReader
    }
    
    // Push adds tr to the top (end) of the input stack. (Popping happens automatically.)
    func (s *Stack) Push(tr TokenReader) {
    	s.tr = append(s.tr, tr)
    }
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jan 09 22:33:23 GMT 2017
    - 1.2K bytes
    - Click Count (0)
  5. okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt

      ) {
      }
    
      /**
       * No further calls to this listener will be made.
       */
      open fun onClosed(eventSource: EventSource) {
      }
    
      /**
       * Invoked when an event source has been closed due to an error reading from or writing to the
       * network. Incoming events may have been lost. No further calls to this listener will be made.
       */
      open fun onFailure(
        eventSource: EventSource,
        t: Throwable?,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 07:51:20 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  6. docs/zh/llm-prompt.md

    ### Target language
    
    Translate to Simplified Chinese (简体中文).
    
    Language code: zh.
    
    ### Grammar and tone
    
    1) Use clear, concise technical Chinese consistent with existing docs.
    2) Address the reader naturally (commonly using “你/你的”).
    
    ### Headings
    
    1) Follow existing Simplified Chinese heading style (short and descriptive).
    2) Do not add trailing punctuation to headings.
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:49:08 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/xml/XmlReaderException.java

     * under the License.
     */
    package org.apache.maven.api.services.xml;
    
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.services.MavenException;
    
    /**
     * An exception thrown while reading an XML file.
     *
     * @since 4.0.0
     */
    @Experimental
    public class XmlReaderException extends MavenException {
    
        private final Location location;
    
        /**
         * @param message the message for the exception
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  8. cmd/bucket-handlers.go

    		apiErr.Description = fmt.Sprintf("%s (%v)", apiErr.Description, err)
    		writeErrorResponse(ctx, w, apiErr, r.URL)
    		return
    	}
    
    	const mapEntryOverhead = 200
    
    	var (
    		reader        io.Reader
    		actualSize    int64 = -1
    		fileName      string
    		fanOutEntries = make([]minio.PutObjectFanOutEntry, 0, 100)
    	)
    
    	maxParts := 1000
    	// Canonicalize the form values into http.Header.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  9. api/go1.5.txt

    pkg mime, type WordDecoder struct
    pkg mime, type WordDecoder struct, CharsetReader func(string, io.Reader) (io.Reader, error)
    pkg mime, type WordEncoder uint8
    pkg mime/quotedprintable, func NewReader(io.Reader) *Reader
    pkg mime/quotedprintable, func NewWriter(io.Writer) *Writer
    pkg mime/quotedprintable, method (*Reader) Read([]uint8) (int, error)
    pkg mime/quotedprintable, method (*Writer) Close() error
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Jul 30 21:14:09 GMT 2015
    - 46.6K bytes
    - Click Count (0)
  10. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

          buf.readShort() // class
          @Suppress("UNUSED_VARIABLE")
          val ttl = buf.readInt().toLong() and 0xffffffffL // ttl
          val length = buf.readShort().toInt() and 0xffff
    
          if (type == TYPE_A || type == TYPE_AAAA) {
            val bytes = ByteArray(length)
            buf.read(bytes)
            result.add(InetAddress.getByAddress(bytes))
          } else {
            buf.skip(length.toLong())
          }
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.9K bytes
    - Click Count (0)
Back to Top