- Sort Score
- Num 10 results
- Language All
Results 431 - 440 of 833 for readFn (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/deadlineconn/deadlineconn.go
c.Conn.SetWriteDeadline(now.Add(c.writeDeadline + updateInterval)) c.writeSetAt = now } } // Read - reads data from the connection using wrapped buffered reader. func (c *DeadlineConn) Read(b []byte) (n int, err error) { if c.abortReads.Load() { return 0, context.DeadlineExceeded } c.setReadDeadline() n, err = c.Conn.Read(b) return n, err } // Write - writes data to the connection.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Dec 02 13:21:17 GMT 2024 - 5.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java
* @param in the input stream to read the mapping data from */ protected void reload(final MappingUpdater updater, final InputStream in) { final Pattern parsePattern = Pattern.compile("(.*?)\\s*+=>\\s*+(.*?)\\s*+$"); final List<CharMappingItem> itemList = new ArrayList<>();Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sat Dec 20 05:56:45 GMT 2025 - 15.3K 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: Sat Dec 20 09:19:18 GMT 2025 - 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 Dec 26 11:42:13 GMT 2025 - Last Modified: Mon Nov 20 15:26:12 GMT 2023 - 1.2K bytes - Click Count (0) -
src/main/java/jcifs/SmbPipeResource.java
/** * The pipe should be opened read-only. */ int PIPE_TYPE_RDONLY = SmbConstants.O_RDONLY; /** * The pipe should be opened only for writing. */ int PIPE_TYPE_WRONLY = SmbConstants.O_WRONLY; /** * The pipe should be opened for both reading and writing. */ int PIPE_TYPE_RDWR = SmbConstants.O_RDWR; /**Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocketListener.kt
webSocket: WebSocket, code: Int, reason: String, ) { } /** * Invoked when both peers have indicated that no more messages will be transmitted and the * connection has been successfully released. No further calls to this listener will be made. */ open fun onClosed( webSocket: WebSocket, code: Int, reason: String, ) { } /**Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 2K bytes - Click Count (0) -
src/bufio/scan_test.go
t.Errorf("#%d: %v", n, err) } } } // slowReader is a reader that returns only a few bytes at a time, to test the incremental // reads in Scanner.Scan. type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p) }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Click Count (0) -
docs/fr/llm-prompt.md
### Target language Translate to French (français). Language code: fr. ### Grammar to use when talking to the reader Use the formal grammar (use «vous» instead of «tu»). ### Quotes 1) Convert neutral double quotes («"») and English double typographic quotes («“» and «”») to French guillemets (««» and «»»). 2) In the French docs, guillemets are written without extra spaces: use «texte», not « texte ».
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 10:41:43 GMT 2025 - 4.1K bytes - Click Count (0) -
src/cmd/addr2line/addr2line_test.go
for scanner.Scan() { f := strings.Fields(scanner.Text()) if len(f) < 3 { continue } syms[f[2]] = f[0] } if err := scanner.Err(); err != nil { t.Fatalf("error reading symbols: %v", err) } return syms } func runAddr2Line(t *testing.T, dbgExePath, addr string) (funcname, path, lineno string) { cmd := testenv.Command(t, testenv.Executable(t), dbgExePath)
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Sep 06 13:23:48 GMT 2024 - 3.2K 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 Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Dec 21 03:10:51 GMT 2024 - 1.8K bytes - Click Count (0)