- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 1,059 for Streams (0.05 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 */ @OverrideCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 3.7K bytes - Click Count (0)