- Sort Score
- Num 10 results
- Language All
Results 871 - 880 of 1,261 for Stream (0.16 seconds)
-
src/test/java/org/codelibs/core/stream/StreamUtilTest.java
}); } public void test_ofNull() { assertEquals(0, (int) StreamUtil.stream().get(s -> s.toArray().length)); Object[] o = {}; assertEquals(0, (int) StreamUtil.stream(o).get(s -> s.toArray().length)); Map<Object, Object> map = new HashMap<Object, Object>(); assertEquals(0, (int) StreamUtil.stream(map).get(s -> s.toArray().length)); } public void test_ofMap() {Created: Fri Apr 03 20:58:12 GMT 2026 - Last Modified: Sat May 10 01:32:17 GMT 2025 - 1.7K bytes - Click Count (0) -
docs/tr/docs/advanced/custom-response.md
Doğrudan bir `StreamingResponse` döndürmek yerine, muhtemelen [Veri Stream Etme](./stream-data.md) bölümündeki tarzı takip etmelisiniz; çok daha kullanışlıdır ve iptali arka planda sizin için halleder. JSON Lines stream ediyorsanız, [JSON Lines Stream Etme](../tutorial/stream-json-lines.md) kılavuzunu izleyin. /// ### `FileResponse` { #fileresponse } Asenkron olarak bir dosyayı response olarak stream eder.
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 07:53:17 GMT 2026 - 11.9K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/release/ReleaseNotesIndexGenerator.java
// For the purpose of generating the index, snapshot versions are the same as released versions. Prerelease versions are not. versionsSet.stream().map(v -> v.isSnapshot() ? v.withoutQualifier() : v).forEach(versions::add); final List<String> includeVersions = versions.stream() .map(v -> v.hasQualifier() ? v.toString() : v.getMajor() + "." + v.getMinor()) .distinct() .collect(Collectors.toList());Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Sep 01 14:45:41 GMT 2021 - 2.1K bytes - Click Count (0) -
docs/es/docs/tutorial/server-sent-events.md
# Server-Sent Events (SSE) { #server-sent-events-sse } Puedes enviar datos en streaming al cliente usando **Server-Sent Events** (SSE). Esto es similar a [Stream JSON Lines](stream-json-lines.md), pero usa el formato `text/event-stream`, que los navegadores soportan de forma nativa con la [`EventSource` API](https://developer.mozilla.org/en-US/docs/Web/API/EventSource). /// info | Información Añadido en FastAPI 0.135.0. ///
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:12:26 GMT 2026 - 5K bytes - Click Count (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
val inputStream = connection.getInputStream() assertThat(inputStream!!.read()).isEqualTo('a'.code) try { val byteRead = inputStream.read() // OpenJDK behavior: end of stream. assertThat(byteRead).isEqualTo(-1) } catch (e: ProtocolException) { // On Android, HttpURLConnection is implemented by OkHttp v2. OkHttp // treats an incomplete response body as a ProtocolException.
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Aug 03 22:38:00 GMT 2025 - 28K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/root/DefaultRootLocator.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.model.root; import javax.inject.Named; import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLStreamException; import javax.xml.stream.XMLStreamReader; import java.io.IOException; import java.io.InputStream; import java.nio.file.Files; import java.nio.file.Path; /**
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 2.6K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/com/SmbComNTCreateAndXTest.java
} @Nested @DisplayName("Constructor createDisposition calculation") class CreateDispositionTests { static java.util.stream.Stream<Arguments> flagsProvider() { return java.util.stream.Stream.of( Arguments.of(SmbConstants.O_TRUNC | SmbConstants.O_CREAT, SmbComNTCreateAndX.FILE_OVERWRITE_IF),Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.6K bytes - Click Count (0) -
compat/maven-model-builder/src/test/java/org/apache/maven/model/building/FileToRawModelMergerTest.java
*/ package org.apache.maven.model.building; import java.lang.reflect.Method; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.List; import java.util.stream.Collectors; import java.util.stream.Stream; import org.apache.maven.model.v4.MavenMerger; import org.junit.jupiter.api.Test; import static org.junit.jupiter.api.Assertions.assertTrue; @Deprecated class FileToRawModelMergerTest {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed Sep 17 10:01:14 GMT 2025 - 2.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/suggest/entity/SuggestItemSerializer.java
import java.time.Instant; import java.time.ZonedDateTime; import java.util.ArrayList; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Stream; import org.codelibs.fess.suggest.constants.FieldNames; import org.codelibs.fess.suggest.util.SuggestUtil; /** * Utility class for serializing and deserializing SuggestItem objects.
Created: Fri Apr 17 09:08:13 GMT 2026 - Last Modified: Sun Feb 01 12:48:24 GMT 2026 - 13.5K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/resolver/filter/ExclusionArtifactFilter.java
this.exclusions = exclusions; this.predicates = exclusions.stream().map(ExclusionArtifactFilter::toPredicate).collect(Collectors.toList()); } @Override public boolean include(Artifact artifact) { return predicates.stream().noneMatch(p -> p.test(artifact)); } private static Predicate<Artifact> toPredicate(Exclusion exclusion) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 3K bytes - Click Count (0)