Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 1,261 for Stream (0.06 seconds)

  1. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildStep.java

            }
        }
    
        public void executeBefore(BuildStep stepToExecuteAfter) {
            stepToExecuteAfter.executeAfter(this);
        }
    
        public Stream<MojoExecution> executions() {
            return mojos.values().stream().flatMap(m -> m.values().stream());
        }
    
        @Override
        public boolean equals(Object o) {
            if (this == o) {
                return true;
            }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Apr 30 16:21:08 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/auth/AuthenticationManager.java

            return chains().get(stream -> stream.allMatch(c -> c.changePassword(username, password)));
        }
    
        /**
         * Deletes a user from all authentication chains.
         * @param user The user to delete.
         */
        public void delete(final User user) {
            chains().of(stream -> stream.forEach(c -> c.delete(user)));
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  3. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/InvokerRequest.java

        /**
         * Returns the input stream for the Maven execution, if running in embedded mode.
         *
         * @return an {@link Optional} containing the input stream, or empty if not applicable
         */
        @Nonnull
        default Optional<InputStream> stdIn() {
            return Optional.ofNullable(parserRequest().stdIn());
        }
    
        /**
         * Returns the output stream for the Maven execution, if running in embedded mode.
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 6.7K bytes
    - Click Count (0)
  4. compat/maven-model/src/test/java/org/apache/maven/model/pom/PomMemoryAnalyzer.java

                long totalOccurrences = stats.values().stream()
                        .mapToLong(StringStats::getOccurrences)
                        .sum();
                long totalMemory = stats.entrySet().stream()
                        .mapToLong(e -> e.getKey().length() * e.getValue().getOccurrences() * 2L)
                        .sum();
                long potentialSavings = stats.entrySet().stream()
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/app/web/base/SearchForm.java

        public String[] getExtraQueries() {
            return stream(ex_q).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
        }
    
        @Override
        public Map<String, String[]> getFields() {
            return fields;
        }
    
        @Override
        public String[] getLanguages() {
            return stream(lang).get(stream -> stream.filter(StringUtil::isNotBlank).distinct().toArray(n -> new String[n]));
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  6. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultArtifactManager.java

            }
        }
    
        /**
         * Retrieve a stream of the project's artifacts.
         * Do not include the POM artifact as the file can't be set anyway.
         */
        private Stream<org.apache.maven.artifact.Artifact> getProjectArtifacts(MavenProject project) {
            return Stream.concat(Stream.of(project.getArtifact()), project.getAttachedArtifacts().stream());
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 16:01:38 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/io/TestStreamSupplier.java

    /**
     * Interface for a supplier of streams that can report whether a stream was opened and whether that
     * stream was closed. Intended for use in a test where only a single stream should be opened and
     * possibly closed.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public interface TestStreamSupplier {
    
      /** Returns whether or not a new stream was opened. */
      boolean wasStreamOpened();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/io/TestStreamSupplier.java

    /**
     * Interface for a supplier of streams that can report whether a stream was opened and whether that
     * stream was closed. Intended for use in a test where only a single stream should be opened and
     * possibly closed.
     *
     * @author Colin Decker
     */
    @NullUnmarked
    public interface TestStreamSupplier {
    
      /** Returns whether or not a new stream was opened. */
      boolean wasStreamOpened();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.1K bytes
    - Click Count (0)
  9. api/maven-api-core/src/main/java/org/apache/maven/api/services/LifecycleRegistry.java

    package org.apache.maven.api.services;
    
    import java.util.List;
    import java.util.stream.Stream;
    import java.util.stream.StreamSupport;
    
    import org.apache.maven.api.Lifecycle;
    
    public interface LifecycleRegistry extends ExtensibleEnumRegistry<Lifecycle>, Iterable<Lifecycle> {
    
        default Stream<Lifecycle> stream() {
            return StreamSupport.stream(spliterator(), false);
        }
    
        List<String> computePhases(Lifecycle lifecycle);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Aug 29 05:48:54 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            this.processDestroyTimeout = processDestroyTimeout;
        }
    
        /**
         * Sets the timeout for stream closing operations.
         *
         * @param streamCloseTimeout timeout in seconds for stream closing operations
         */
        public void setStreamCloseTimeout(final int streamCloseTimeout) {
            this.streamCloseTimeout = streamCloseTimeout;
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 06:54:47 GMT 2025
    - 10.9K bytes
    - Click Count (0)
Back to Top