Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 261 for ForEach (0.13 sec)

  1. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/CommonsCliOptions.java

                CommandLine commandLine = parser.parse(options, cleanArgs);
                // to trigger deprecation handler, so we can report deprecation BEFORE we actually use options
                options.getOptions().forEach(commandLine::hasOption);
                return commandLine;
            }
    
            protected void addDeprecatedOption(Option option) {
                usedDeprecatedOptions.add(option);
            }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/es/config/exentity/DataConfig.java

            } else if (Constants.NTLM.equals(scheme)) {
                final Properties props = new Properties();
                paramMap.entrySet().stream().filter(e -> e.getKey().startsWith("jcifs.")).forEach(e -> {
                    props.setProperty(e.getKey(), e.getValue());
                });
                authScheme = new NTLMScheme(new JcifsEngine(props));
            } else if (Constants.FORM.equals(scheme)) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 12 01:54:15 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/CLIManager.java

            CommandLine commandLine = parser.parse(options, cleanArgs);
            // to trigger deprecation handler, so we can report deprecation BEFORE we actually use options
            options.getOptions().forEach(commandLine::hasOption);
            return commandLine;
        }
    
        public Set<Option> getUsedDeprecatedOptions() {
            return usedDeprecatedOptions;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/util/ComponentUtil.java

            } else {
                initProcesses.add(process);
            }
        }
    
        public static void doInitProcesses(final Consumer<? super Runnable> action) {
            try {
                initProcesses.forEach(action);
            } finally {
                initProcesses.clear();
            }
        }
    
        public static CachedCipher getCipher(final String cipherName) {
            return getComponent(cipherName);
        }
    
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Mon Jun 17 13:35:51 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/ImmutableSortedMap.java

          }
    
          @Override
          public Spliterator<Entry<K, V>> spliterator() {
            return asList().spliterator();
          }
    
          @Override
          public void forEach(Consumer<? super Entry<K, V>> action) {
            asList().forEach(action);
          }
    
          @Override
          ImmutableList<Entry<K, V>> createAsList() {
            return new ImmutableAsList<Entry<K, V>>() {
              @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          // call to addListener() will callback to setOneValue(), transitively call our cleanup
          // listener, and set this.futures to null.
          // This is not actually a problem, since the foreach only needs this.futures to be non-null
          // at the beginning of the loop.
          int i = 0;
          for (ListenableFuture<? extends InputT> future : futures) {
            int index = i++;
            if (future.isDone()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/LinkedHashMultimap.java

              ValueSet.this.remove(toRemove.getValue());
              expectedModCount = modCount;
              toRemove = null;
            }
          };
        }
    
        @Override
        public void forEach(Consumer<? super V> action) {
          checkNotNull(action);
          for (ValueSetLink<K, V> entry = firstEntry;
              entry != ValueSet.this;
              entry = entry.getSuccessorInValueSet()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 24.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/LinkedListMultimap.java

            return size;
          }
    
          @Override
          public ListIterator<Entry<K, V>> listIterator(int index) {
            return new NodeIterator(index);
          }
    
          @Override
          public void forEach(Consumer<? super Entry<K, V>> action) {
            checkNotNull(action);
            for (Node<K, V> node = head; node != null; node = node.next) {
              action.accept(node);
            }
          }
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 13 14:11:58 UTC 2023
    - 27.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/io/CharSource.java

       *
       * <pre>{@code
       * try (Stream<String> lines = source.lines()) {
       *   lines.map(...)
       *      .filter(...)
       *      .forEach(...);
       * }
       * }</pre>
       *
       * @throws IOException if an I/O error occurs while opening the stream
       * @since 22.0 (but only since 33.4.0 in the Android flavor)
       */
      @MustBeClosed
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 25.5K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        this.withLock {
          if (streams.isNotEmpty()) {
            streamsToClose = streams.values.toTypedArray()
            streams.clear()
          }
        }
    
        streamsToClose?.forEach { stream ->
          ignoreIoExceptions {
            stream.close(streamCode, cause)
          }
        }
    
        // Close the writer to release its resources (such as deflaters).
        ignoreIoExceptions {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
Back to top