- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 716 for STREAM (2.24 sec)
-
src/mdo/model-v3.vm
#if ( $field.to == "String" ) update(getDelegate().with${cap}( Stream.concat(getDelegate().get${cap}().stream(), Stream.of(${v})) .collect(Collectors.toList()))); #else update(getDelegate().with${cap}( Stream.concat(getDelegate().get${cap}().stream(), Stream.of(${v}.getDelegate())) .collect(Collectors.toList())));
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Nov 06 19:04:44 UTC 2023 - 13.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/ReactorReader.java
} } /** * Retrieve a stream of the project's artifacts */ private Stream<Artifact> getProjectArtifacts(MavenProject project) { Stream<org.apache.maven.artifact.Artifact> artifacts = Stream.concat( Stream.concat( // pom artifact Stream.of(new ProjectArtifact(project)),
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu May 02 16:33:18 UTC 2024 - 21.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableListMultimap.java
private void writeObject(ObjectOutputStream stream) throws IOException { stream.defaultWriteObject(); Serialization.writeMultimap(this, stream); } @GwtIncompatible // java.io.ObjectInputStream @J2ktIncompatible private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException { stream.defaultReadObject(); int keyCount = stream.readInt(); if (keyCount < 0) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Aug 24 01:40:03 UTC 2023 - 17.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/aad/AzureAdAuthenticator.java
final Pair<String[], String[]> groupsAndRoles = getParentGroup(user, id); StreamUtil.stream(groupsAndRoles.getFirst()).of(stream -> stream.forEach(groupList::add)); StreamUtil.stream(groupsAndRoles.getSecond()).of(stream -> stream.forEach(roleList::add)); } protected Pair<String[], String[]> getParentGroup(final AzureAdUser user, final String id) { try {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 28.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java
} } final DuplicateHostHelper duplicateHostHelper = ComponentUtil.getDuplicateHostHelper(); // set urls split(urlsStr, "[\r\n]").of(stream -> stream.filter(StringUtil::isNotBlank).map(String::trim).distinct().forEach(urlValue -> { if (!urlValue.startsWith("#") && fessConfig.isValidCrawlerWebProtocol(urlValue)) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 22.6K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.crawler; import static org.codelibs.core.stream.StreamUtil.split; import static org.codelibs.core.stream.StreamUtil.stream; import java.util.ArrayList; import java.util.Collections; import java.util.Date; import java.util.HashMap; import java.util.HashSet; import java.util.LinkedHashSet;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 14.6K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/DefaultMaven.java
} } final Stream<String> projectProfiles = projectsIncludingParents.stream() .flatMap(p -> p.getModel().getDelegate().getProfiles().stream()) .map(Profile::getId); final Stream<String> settingsProfiles = session.getSettings().getProfiles().stream().map(org.apache.maven.settings.Profile::getId);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 27.5K bytes - Viewed (0) -
platforms/native/language-native/src/main/java/org/gradle/language/swift/plugins/SwiftLibraryPlugin.java
} private Stream<SwiftBinary> getDebugStream() { return library.getBinaries().get().stream().filter(binary -> !binary.isOptimized()); } private Stream<SwiftBinary> getDebugSharedStream() { return getDebugStream().filter(SwiftSharedLibrary.class::isInstance); } private Stream<SwiftBinary> getDebugSharedHostStream() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 10.8K bytes - Viewed (0) -
platforms/software/resources-s3/src/integTest/groovy/org/gradle/integtests/resource/s3/S3ClientIntegrationTest.groovy
} S3Client s3Client = new S3Client(authenticationImpl, s3SystemProperties) when: def stream = new FileInputStream(file) def uri = new URI("s3://${bucketName}/maven/release/$FILE_NAME") then: s3Client.put(stream, file.length(), uri) when: server.stubMetaData(file, "/${bucketName}/maven/release/$FILE_NAME")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 9.8K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_device.h
// performed by host_to_device/device_to_device stream or borrowing a stream // for each device to host transfer. const bool use_multiple_streams_; // If use_multiple_streams_, host to device transfers are performed using this // stream. std::shared_ptr<se::Stream> host_to_device_stream_ TF_GUARDED_BY(mu_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 09:53:30 UTC 2024 - 13.4K bytes - Viewed (0)