- Sort Score
- Num 10 results
- Language All
Results 271 - 280 of 1,215 for stream (0.04 seconds)
-
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java
public Type require(String id) { requireNonNull(id, "id cannot be null"); return usedTypes.computeIfAbsent(id, i -> { Type type = lookup.lookupList(TypeProvider.class).stream() .flatMap(p -> p.provides().stream()) .filter(t -> Objects.equals(id, t.id())) .findFirst() .orElse(null); if (type == null) {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Wed May 14 04:47:58 GMT 2025 - 4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/relatedquery/ApiAdminRelatedqueryAction.java
*/ package org.codelibs.fess.app.web.api.admin.relatedquery; import static org.codelibs.core.stream.StreamUtil.stream; import static org.codelibs.fess.app.web.admin.relatedquery.AdminRelatedqueryAction.getRelatedQuery; import java.util.List; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.lang.StringUtil;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 8.4K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java
import java.io.IOException; import java.nio.file.Files; import java.nio.file.attribute.PosixFileAttributeView; import java.nio.file.attribute.PosixFilePermission; import java.util.List; import java.util.Set; import java.util.stream.Collectors; import org.apache.tools.ant.taskdefs.condition.Os; import org.gradle.api.DefaultTask; import org.gradle.api.GradleException; import org.gradle.api.file.FileCollection; import org.gradle.api.file.FileTree;
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanLogger.java
import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.Set; import java.util.function.Consumer; import java.util.stream.Collectors; import java.util.stream.Stream; import org.apache.maven.plugin.MojoExecution; import org.apache.maven.project.MavenProject; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * <p>
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sun Mar 30 23:08:36 GMT 2025 - 7.1K bytes - Click Count (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
server.enqueue( MockResponse .Builder() .body( """ |data: hey | | """.trimMargin(), ).setHeader("content-type", "text/event-stream") .build(), ) val request = Request.Builder().url(server.url("/")).build() val response = client.newCall(request).execute() processResponse(response, listener) listener.assertOpen()
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Oct 03 07:51:20 GMT 2025 - 3.6K bytes - Click Count (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java
*/ Model read(Reader input, Map<String, ?> options) throws IOException, ModelParseException; /** * Reads the model from the specified byte stream. The stream will be automatically closed before the method * returns. * * @param input The stream to deserialize the model from, must not be {@code null}. * @param options The options to use for deserialization, may be {@code null} to use the default values.Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Tue Feb 25 08:27:34 GMT 2025 - 3.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultProject.java
return Stream.iterate(this.project, Objects::nonNull, MavenProject::getParent) .flatMap(project -> project.getModel().getDelegate().getProfiles().stream()) .toList(); } @Override @Nonnull public List<Profile> getDeclaredActiveProfiles() { return project.getActiveProfiles().stream()
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Mon Mar 24 22:23:23 GMT 2025 - 8.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/dict/synonym/ApiAdminDictSynonymAction.java
validateApi(body, messages -> {}); return synonymService.getSynonymFile(body.dictId) .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { file.writeOut(out); })) .orElseGet(() -> { throwValidationErrorApi(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL));
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 9.3K bytes - Click Count (0) -
docs/en/docs/reference/responses.md
There are several custom response classes you can use to create an instance and return them directly from your *path operations*. Read more about it in the [FastAPI docs for Custom Response - HTML, Stream, File, others](https://fastapi.tiangolo.com/advanced/custom-response/). You can import them directly from `fastapi.responses`: ```python from fastapi.responses import ( FileResponse, HTMLResponse,
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Sun Feb 22 16:34:59 GMT 2026 - 4.4K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
* values for that key, and the key's values */ @GwtIncompatible @J2ktIncompatible private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); stream.writeObject(valueComparator()); Serialization.writeMultimap(this, stream); } private @Nullable Comparator<? super V> valueComparator() { return emptySet instanceof ImmutableSortedSet
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 19 22:57:35 GMT 2026 - 26.3K bytes - Click Count (0)