Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 331 - 340 of 1,261 for Stream (0.13 seconds)

  1. android/guava/src/com/google/common/collect/CollectCollectors.java

    import java.util.TreeMap;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.function.Supplier;
    import java.util.function.ToIntFunction;
    import java.util.stream.Collector;
    import java.util.stream.Stream;
    import org.jspecify.annotations.Nullable;
    
    /** Collectors utilities for {@code common.collect} internals. */
    @GwtCompatible
    @IgnoreJRERequirement // used only from APIs with Java 8 types in them
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 16.9K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/CollectCollectors.java

    import java.util.TreeMap;
    import java.util.function.BinaryOperator;
    import java.util.function.Function;
    import java.util.function.Supplier;
    import java.util.function.ToIntFunction;
    import java.util.stream.Collector;
    import java.util.stream.Stream;
    import org.jspecify.annotations.Nullable;
    
    /** Collectors utilities for {@code common.collect} internals. */
    @GwtCompatible
    final class CollectCollectors {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  3. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/ModelVersionUtilsTest.java

     * KIND, either express or implied.  See the License for the
     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.invoker.mvnup.goals;
    
    import java.util.stream.Stream;
    
    import eu.maveniverse.domtrip.Document;
    import eu.maveniverse.domtrip.Element;
    import eu.maveniverse.domtrip.Parser;
    import org.junit.jupiter.api.DisplayName;
    import org.junit.jupiter.api.Nested;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 19.6K bytes
    - Click Count (0)
  4. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/ForbiddenPatternsPrecommitPlugin.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 ForbiddenPatternsPrecommitPlugin extends PrecommitPlugin implements InternalPlugin {
    
        public static final String FORBIDDEN_PATTERNS_TASK_NAME = "forbiddenPatterns";
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 1.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/io/ByteProcessor.java

    import com.google.errorprone.annotations.DoNotMock;
    import java.io.IOException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A callback interface to process bytes from a stream.
     *
     * <p>{@link #processBytes} will be called for each chunk of data that is read, and should return
     * {@code false} when you want to stop processing.
     *
     * @author Chris Nokleberg
     * @since 1.0
     */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/LineBuffer.java

     * or carriage return followed immediately by a linefeed.
     *
     * <p>Subclasses must implement {@link #handleLine}, call {@link #add} to pass character data, and
     * call {@link #finish} at the end of stream.
     *
     * @author Chris Nokleberg
     * @since 1.0
     */
    @J2ktIncompatible
    @GwtIncompatible
    abstract class LineBuffer {
      /** Holds partial line contents. */
      private StringBuilder line = new StringBuilder();
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 18 02:54:30 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/io/MoreFiles.java

        try (DirectoryStream<Path> stream = Files.newDirectoryStream(path)) {
          if (stream instanceof SecureDirectoryStream) {
            SecureDirectoryStream<Path> sds = (SecureDirectoryStream<Path>) stream;
            exceptions = deleteDirectoryContentsSecure(sds);
          } else {
            checkAllowsInsecure(path, options);
            exceptions = deleteDirectoryContentsInsecure(stream);
          }
        } catch (IOException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Apr 14 16:07:06 GMT 2025
    - 34.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                        } else {
                            ignoreFields = new String[] { Constants.INDEXING_TARGET, Constants.SESSION_ID };
                        }
                        stream(ignoreFields).of(stream -> stream.map(String::trim).forEach(s -> dataMap.remove(s)));
    
                        indexUpdateCallback.store(paramMap, dataMap);
                        crawlerStatsHelper.record(keyObj, StatsAction.PROCESSED);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 29.7K bytes
    - Click Count (3)
  9. src/main/java/org/codelibs/fess/opensearch/log/exbhv/SearchLogBhv.java

                final Object searchFieldObj = source.get("searchField");
                if (searchFieldObj instanceof Map) {
                    ((Map<String, ?>) searchFieldObj).entrySet().stream().forEach(e -> {
                        if (e.getValue() instanceof String[]) {
                            final String[] values = (String[]) e.getValue();
                            for (final String v : values) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 15 06:53:53 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/util/MimeMap.java

        }
    
        /**
         * Returns the MIME type for the given file extension.
         * If no mapping is found, returns "application/octet-stream" as the default.
         *
         * @param extension the file extension to look up (without the dot)
         * @return the MIME type for the extension, or "application/octet-stream" if not found
         * @throws IOException if there is an error processing the MIME mappings
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.1K bytes
    - Click Count (0)
Back to Top