Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 1,059 for Streams (0.05 seconds)

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

            return new ProjectBuildList(
                    items.stream().filter(pb -> taskSegment == pb.getTaskSegment()).collect(Collectors.toList()));
        }
    
        public Map<MavenProject, ProjectSegment> selectSegment(TaskSegment taskSegment) {
            return items.stream()
                    .filter(pb -> taskSegment == pb.getTaskSegment())
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  2. build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    import java.util.function.BiConsumer;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    import java.util.stream.Stream;
    
    /**
     * NOTICE: this class is invoked via java command line, so we must NOT DEPEND ON ANY 3RD-PARTY LIBRARIES except JDK 11.
     *
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Sep 23 13:49:45 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. compat/maven-model/src/main/java/org/apache/maven/model/io/xpp3/MavenXpp3WriterEx.java

        } // -- void write( Writer, Model )
    
        /**
         * Method write.
         *
         * @param stream a stream object.
         * @param model a model object.
         * @throws IOException java.io.IOException if any.
         */
        @Override
        public void write(OutputStream stream, Model model) throws IOException {
            super.write(stream, model);
        } // -- void write( OutputStream, Model )
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycles.java

                        ? registry.stream().collect(Collectors.toMap(lf -> lf.id(), lf -> new Lifecycle(registry, lf)))
                        : Map.of();
            } catch (LookupException e) {
                throw new IllegalStateException("Unable to lookup lifecycles from the plexus container", e);
            }
        }
    
        public String getLifecyclePhaseList() {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. src/test/java/jcifs/http/NtlmHttpURLConnectionTest.java

                }
            }
    
            if (code >= 400 && stream != null) {
                when(conn.getErrorStream()).thenReturn(stream);
            } else if (stream != null) {
                when(conn.getInputStream()).thenReturn(stream);
            }
        }
    
        /**
         * Test helper class for mocking URL.openConnection() behavior
         */
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/CountingOutputStream.java

     */
    @J2ktIncompatible
    @GwtIncompatible
    public final class CountingOutputStream extends FilterOutputStream {
    
      private long count;
    
      /**
       * Wraps another output stream, counting the number of bytes written.
       *
       * @param out the output stream to be wrapped
       */
      public CountingOutputStream(OutputStream out) {
        super(checkNotNull(out));
      }
    
      /** Returns the number of bytes written. */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.9K bytes
    - Click Count (0)
  7. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/ParserRequest.java

        @Nullable
        Path userHome();
    
        /**
         * Returns the input stream to be used for the Maven execution.
         * If not set, {@link System#in} will be used by default.
         *
         * @return the input stream, or null if not set
         */
        @Nullable
        InputStream stdIn();
    
        /**
         * Returns the output stream to be used for the Maven execution.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sat Jun 07 06:22:47 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  8. src/main/java/jcifs/FileNotifyInformation.java

         */
        int FILE_ACTION_RENAMED_NEW_NAME = 0x00000005;
    
        /**
         * File stream has been added
         */
        int FILE_ACTION_ADDED_STREAM = 0x00000006;
        /**
         * File stream has been removed
         */
        int FILE_ACTION_REMOVED_STREAM = 0x00000007;
        /**
         * File stream has modified
         */
        int FILE_ACTION_MODIFIED_STREAM = 0x00000008;
    
        /**
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/SitemapsHelper.java

        }
    
        /**
         * Checks if the given input stream contains valid sitemap data.
         * @param in the input stream to validate
         * @return true if the stream contains valid sitemap data, false otherwise
         */
        public boolean isValid(final InputStream in) {
            return isValid(in, true);
        }
    
        /**
         * Checks if the given input stream contains valid sitemap data.
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Fri Nov 14 13:19:40 GMT 2025
    - 34.9K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb/SmbPipeHandleInternal.java

        /**
         * Gets the input stream for reading from this pipe.
         *
         * @return this pipe's input stream
         * @throws CIFSException if an error occurs getting the input stream
         */
        @Override
        SmbPipeInputStream getInput() throws CIFSException;
    
        /**
         *
         * @return this pipe's output stream
         * @throws CIFSException if an error occurs
         */
        @Override
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.7K bytes
    - Click Count (0)
Back to Top