- Sort Score
- Num 10 results
- Language All
Results 511 - 520 of 1,019 for readFn (0.1 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 exceptionCreated: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Sat Apr 05 11:52:05 GMT 2025 - 1.4K bytes - Click Count (0) -
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) -
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) -
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)