- Sort Score
- Result 10 results
- Languages All
Results 921 - 930 of 1,022 for Streams (0.04 sec)
-
android/guava/src/com/google/common/primitives/UnsignedLongs.java
* compares, using {@link #compare(long, long)}), the first pair of values that follow any common * prefix, or when one array is a prefix of the other, treats the shorter array as the lesser. For * example, {@code [] < [1L] < [1L, 2L] < [2L] < [1L << 63]}. * * <p>The returned comparator is inconsistent with {@link Object#equals(Object)} (since arraysRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 17.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/artifact/MavenMetadataSource.java
MavenSession session = legacySupport.getSession(); if (session != null) { if (session.getProjects() != null) { pomRepositories = session.getProjects().stream() .filter(p -> artifact.equals(p.getArtifact())) .findFirst() .map(MavenProject::getRemoteArtifactRepositories)
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Sep 25 12:03:50 UTC 2025 - 30.4K bytes - Viewed (0) -
docs/ko/docs/advanced/custom-response.md
# 사용자 정의 응답 - HTML, Stream, 파일, 기타 기본적으로, **FastAPI** 응답을 `JSONResponse`를 사용하여 반환합니다. 이를 재정의 하려면 [응답을 직접 반환하기](response-directly.md){.internal-link target=_blank}에서 본 것처럼 `Response`를 직접 반환하면 됩니다. 그러나 `Response` (또는 `JSONResponse`와 같은 하위 클래스)를 직접 반환하면, 데이터가 자동으로 변환되지 않으며 (심지어 `response_model`을 선언했더라도), 문서화가 자동으로 생성되지 않습니다(예를 들어, 생성된 OpenAPI의 일부로 HTTP 헤더 `Content-Type`에 특정 "미디어 타입"을 포함하는 경우).Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Feb 15 11:21:20 UTC 2025 - 13.4K bytes - Viewed (0) -
cmd/encryption-v1_test.go
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 19.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
default: return xml.UnmarshalError(fmt.Sprintf("expected element type <LifecycleConfiguration>/<BucketLifecycleConfiguration> but have <%s>", start.Name.Local)) } for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { switch se.Name.Local { case "Rule":
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Apr 03 06:45:06 UTC 2025 - 18.2K bytes - Viewed (0) -
cmd/erasure-object.go
} return fi.ToObjectInfo(minioMetaBucket, key, opts.Versioned || opts.VersionSuspended), nil } // PutObject - creates an object upon reading from the input stream // until EOF, erasure codes the data across all disk and additionally // writes `xl.meta` which carries the necessary metadata for future // object operations.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 80.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/api/engine/SearchEngineApiManager.java
if (StringUtil.isNotEmpty(contentType)) { curlRequest.header("Content-Type", contentType); } request.getParameterMap().entrySet().stream().forEach(entry -> { if (entry.getValue().length > 1) { curlRequest.param(entry.getKey(), String.join(",", entry.getValue())); } else if (entry.getValue().length == 1) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Fri Nov 28 16:29:12 UTC 2025 - 12.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/SMB1SigningDigest.java
update(sequence, 0, sequence.length); index += 8; if (msg.getCommand() == ServerMessageBlock.SMB_COM_READ_ANDX) { /* * SmbComReadAndXResponse reads directly from the stream into separate byte[] b. */ final SmbComReadAndXResponse raxr = (SmbComReadAndXResponse) msg; final int length = msg.getLength() - raxr.getDataLength();
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 11.9K bytes - Viewed (0) -
docs/features/https.md
for ((name, value) in response.headers) { println("$name: $value") } println(response.body!!.string()) } } /** * Returns an input stream containing one or more certificate PEM files. This implementation just * embeds the PEM files in Java strings; most applications will instead read this from a resource * file that gets bundled with the application.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat Dec 24 00:16:30 UTC 2022 - 10.5K bytes - Viewed (0) -
internal/s3select/csv/reader.go
bufferPool bpool.Pool[[]byte] // pool of []byte objects for input csvDstPool bpool.Pool[[][]string] // pool of [][]string used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 8.8K bytes - Viewed (0)