Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 401 - 410 of 1,215 for stream (0.06 seconds)

  1. 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 than
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sun Apr 13 18:50:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top