Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 1,215 for stream (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top