- Sort Score
- Result 10 results
- Languages All
Results 451 - 460 of 914 for readFn (0.04 sec)
-
internal/bucket/bandwidth/monitor_gen.go
// Code generated by github.com/tinylib/msgp DO NOT EDIT. package bandwidth import ( "github.com/tinylib/msgp/msgp" ) // DecodeMsg implements msgp.Decodable func (z *BucketBandwidthReport) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader() if err != nil { err = msgp.WrapError(err) return } for zb0001 > 0 { zb0001--
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/RepositoryUtils.java
} public static WorkspaceRepository getWorkspace(RepositorySystemSession session) { WorkspaceReader reader = session.getWorkspaceReader(); return (reader != null) ? reader.getRepository() : null; } public static boolean repositoriesEquals(List<RemoteRepository> r1, List<RemoteRepository> r2) { if (r1.size() != r2.size()) {Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Sep 04 18:33:16 UTC 2025 - 15.8K bytes - Viewed (0) -
cmd/erasure-encode_test.go
return nil, errFaultyDisk } func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error { return errFaultyDisk } func (badDisk) Hostname() string { return "" } const oneMiByte = 1 * humanize.MiByte var erasureEncodeTests = []struct { dataBlocks int
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 11.8K bytes - Viewed (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?,Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Oct 03 07:51:20 UTC 2025 - 1.4K bytes - Viewed (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.
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 27 18:49:08 UTC 2025 - 1.4K bytes - Viewed (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<>();Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 05:56:45 UTC 2025 - 15.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java
verifyToken(this::asUploadHtml); CommonPoolUtil.execute(() -> { try (Reader reader = new BufferedReader(new InputStreamReader(form.elevateWordFile.getInputStream(), getCsvEncoding()))) { elevateWordService.importCsv(reader); suggestHelper.deleteAllElevateWord(false); suggestHelper.storeAllElevateWords(false);
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 20 13:56:35 UTC 2025 - 22.2K bytes - Viewed (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 ».
Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Wed Dec 17 10:41:43 UTC 2025 - 4.1K bytes - Viewed (0) -
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.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Dec 02 13:21:17 UTC 2024 - 5.1K bytes - Viewed (0) -
cmd/warm-backend-azure.go
destObj := object if az.Prefix != "" { destObj = fmt.Sprintf("%s/%s", az.Prefix, object) } return destObj } func (az *warmBackendAzure) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { azMeta := map[string]*string{} for k, v := range meta { azMeta[k] = to.Ptr(v) }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0)