- Sort Score
- Num 10 results
- Language All
Results 401 - 410 of 1,215 for stream (0.09 seconds)
-
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/cisupport/CIDetectorHelper.java
* under the License. */ package org.apache.maven.cling.invoker.cisupport; import java.util.ArrayList; import java.util.List; import java.util.Optional; import java.util.ServiceLoader; import java.util.stream.Collectors; import org.apache.maven.api.cli.cisupport.CIInfo; /** * CI detector helper: it uses service discovery to discover {@link CIDetector}s. If resulting list has more thanCreated: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Sun Apr 13 18:50:07 GMT 2025 - 1.9K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/Lifecycles.java
} @Override public List<Lifecycle.Phase> phases() { return phases; } @Override public Stream<Lifecycle.Phase> allPhases() { return Stream.concat(Stream.of(this), phases().stream().flatMap(Lifecycle.Phase::allPhases)); } } static class DefaultAlias implements Lifecycle.Alias { private final String v3Phase;Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Mar 28 15:21:19 GMT 2025 - 8.4K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/info/GlobalBuildInfoPlugin.java
}).collect(Collectors.toList()); } private Stream<InstallationLocation> getAvailableJavaInstallationLocationSteam() { return Stream.concat( javaInstallationRegistry.listInstallations().stream(), Stream.of(new InstallationLocation(Jvm.current().getJavaHome(), "Current JVM")) ); }
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Aug 17 10:02:58 GMT 2021 - 18.1K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsPrecommitPlugin.java
import org.gradle.api.Project; import org.gradle.api.Task; import org.gradle.api.provider.ProviderFactory; import org.gradle.api.tasks.TaskProvider; import javax.inject.Inject; import java.util.stream.Collectors; public class FilePermissionsPrecommitPlugin extends PrecommitPlugin implements InternalPlugin { public static final String FILEPERMISSIONS_TASK_NAME = "filepermissions";Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 1.7K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbUnsupportedOperationExceptionTest.java
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.when; import java.util.function.Supplier; import java.util.stream.Stream; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.2K bytes - Click Count (0) -
src/test/java/jcifs/smb/SMBProtocolDowngradeExceptionTest.java
import static org.junit.jupiter.api.Assertions.assertSame; import static org.junit.jupiter.api.Assertions.assertThrows; import static org.junit.jupiter.api.Assertions.assertTrue; import java.io.IOException; import java.util.stream.Stream; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.junit.jupiter.params.ParameterizedTest;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/timer/HotThreadMonitorTarget.java
* either express or implied. See the License for the specific language * governing permissions and limitations under the License. */ package org.codelibs.fess.timer; import java.util.stream.Collectors; import org.apache.commons.text.StringEscapeUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.fess.Constants;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 3.7K bytes - Click Count (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java
// FIXME There should be no duplicates, yet there are some return upgradedProperties.stream() .distinct() .collect(ImmutableList.toImmutableList()); } catch (IOException e) { throw UncheckedException.throwAsUncheckedException(e); } }Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Wed Dec 24 14:15:15 GMT 2025 - 9.3K bytes - Click Count (0) -
android/guava/src/com/google/common/math/Stats.java
import java.io.Serializable; import java.nio.ByteBuffer; import java.nio.ByteOrder; import java.util.Iterator; import java.util.Objects; import java.util.stream.Collector; import java.util.stream.DoubleStream; import java.util.stream.IntStream; import java.util.stream.LongStream; import org.jspecify.annotations.Nullable; /** * A bundle of statistical summary values -- sum, count, mean/average, min and max, and several
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Jul 08 18:32:10 GMT 2025 - 25.1K bytes - Click Count (0) -
internal/s3select/csv/args.go
args.QuoteEscapeCharacter = defaultQuoteEscapeCharacter args.CommentCharacter = defaultCommentCharacter args.AllowQuotedRecordDelimiter = false for { // Read tokens from the XML document in a stream. t, err := d.Token() if err != nil { if err == io.EOF { break } return err } if se, ok := t.(xml.StartElement); ok { tagName := se.Name.Local switch tagName {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 20 18:31:45 GMT 2024 - 5.7K bytes - Click Count (0)