- Sort Score
- Num 10 results
- Language All
Results 411 - 420 of 841 for readFn (0.07 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Aug 04 20:35:21 GMT 2022 - 3K bytes - Click Count (0) -
guava/src/com/google/common/base/Ticker.java
public abstract long read(); /** * A ticker that reads the current time using {@link System#nanoTime}. * * @since 10.0 */ public static Ticker systemTicker() { return SYSTEM_TICKER; } private static final Ticker SYSTEM_TICKER = new Ticker() { @Override @SuppressWarnings("GoodTime") // reading system time without TimeSourceCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.8K bytes - Click Count (0) -
docs/auditlog/auditlog-echo.go
flag.IntVar(&port, "port", 8080, "Port to listen on") } func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err) w.WriteHeader(http.StatusBadRequest) return } log.Printf(">>> %s %s\n", r.Method, r.URL.Path) var out bytes.Buffer json.Indent(&out, body, "", " ")
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed May 01 21:31:13 GMT 2024 - 1.5K bytes - Click Count (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Decrypt.java
super(messageBuilderFactory, secDispatcher); } @Override protected int doExecute(EncryptContext context) throws Exception { String encrypted = context.reader.readLine("Enter the password to decrypt: "); if (secDispatcher.isAnyEncryptedString(encrypted)) { context.terminal.writer().println(secDispatcher.decrypt(encrypted)); return OK; } else {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Dec 17 09:50:45 GMT 2024 - 2.1K bytes - Click Count (0) -
internal/http/close.go
// // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it. // If resp.Body is not closed, the Client's underlying RoundTripper // (typically Transport) may not be able to reuse a persistent TCP // connection to the server for a subsequent "keep-alive" request.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K 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 Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 3.9K bytes - Click Count (0) -
guava/src/com/google/common/collect/LinkedHashMultiset.java
} @GwtIncompatible @J2ktIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); int distinctElements = stream.readInt(); setBackingMap(new LinkedHashMap<E, Count>()); Serialization.populateMultiset(this, stream, distinctElements); } @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Dec 05 23:15:58 GMT 2025 - 3.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ServerTruncatesRequestTest.kt
@BeforeEach fun setUp() { platform.assumeNotOpenJSSE() platform.assumeHttp2Support() } @Test fun serverTruncatesRequestOnLongPostHttp1() { // "java.net.SocketException: Socket closed" thrown reading response after // "java.net.SocketException: Connection reset by peer" writing request assumeNotWindows() serverTruncatesRequestOnLongPost(https = false) } @Test
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Jan 11 11:54:15 GMT 2026 - 10.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/DictionaryException.java
import org.codelibs.fess.exception.FessSystemException; /** * Exception thrown when dictionary operations encounter errors. * This exception is typically used for issues during dictionary file * reading, writing, parsing, or other dictionary-related operations. */ public class DictionaryException extends FessSystemException { /** Serial version UID for serialization. */Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 1.6K bytes - Click Count (0) -
deploy_website.sh
cd $DIR # Generate the API docs ./gradlew dokkaHtmlMultiModule mv ./build/dokka/htmlMultiModule docs/5.x # Copy in special files that GitHub wants in the project root. cat README.md | grep -v 'project website' > docs/index.md cp CHANGELOG.md docs/changelogs/changelog.md cp CONTRIBUTING.md docs/contribute/contributing.md # Build the site and push the new files up to GitHub python3 -m venv venv
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Nov 20 15:26:12 GMT 2023 - 1.2K bytes - Click Count (0)