Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 298 for consumers (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. guava/src/com/google/common/collect/ImmutableSet.java

          return CollectSpliterators.indexed(size(), SPLITERATOR_CHARACTERISTICS, this::get);
        }
    
        @Override
        public void forEach(Consumer<? super E> consumer) {
          checkNotNull(consumer);
          int n = size();
          for (int i = 0; i < n; i++) {
            consumer.accept(get(i));
          }
        }
    
        @Override
        int copyIntoArray(@Nullable Object[] dst, int offset) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Nov 07 16:09:47 GMT 2025
    - 35.3K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

         *
         * @param success A callback for successful indexing.
         * @param error   A callback for indexing errors.
         */
        public void indexFromDocuments(final Consumer<Boolean> success, final Consumer<Throwable> error) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
            final long interval = fessConfig.getSuggestUpdateRequestIntervalAsInteger().longValue();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/dfs/DfsReferralDataInternal.java

         *
         * @param domain the domain name to append
         */
        void fixupDomain(String domain);
    
        /**
         * Reduces path consumed by the given value
         *
         * @param i the number of characters to strip from path consumed
         */
        void stripPathConsumed(int i);
    
        @Override
        DfsReferralDataInternal next();
    
        /**
         * Set the UNC path link for this referral
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

        class MockCurlRequest extends CurlRequest {
    
            MockCurlRequest(Curl.Method method, String url) {
                super(method, url);
            }
    
            @Override
            public void connect(Consumer<HttpURLConnection> actionListener, Consumer<Exception> exceptionListener) {
                try {
                    actionListener.accept(new MockHttpURLConnection(new URL(url)));
                } catch (MalformedURLException e) {
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 12:00:34 GMT 2026
    - 44.1K bytes
    - Click Count (0)
  5. docs/en/docs/deployment/docker.md

    This way, containers consume **little resources**, an amount comparable to running the processes directly (a virtual machine would consume much more).
    
    Containers also have their own **isolated** running processes (commonly just one process), file system, and network, simplifying deployment, security, development, etc.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 28.3K bytes
    - Click Count (1)
  6. benchmarks/src/main/java/org/elasticsearch/common/RoundingBenchmark.java

            for (int i = 0; i < dates.length; i++) {
                bh.consume(rounder.round(dates[i]));
            }
        }
    
        @Benchmark
        public void nextRoundingValue(Blackhole bh) {
            Rounding.Prepared rounder = rounderBuilder.get();
            for (int i = 0; i < dates.length; i++) {
                bh.consume(rounder.nextRoundingValue(dates[i]));
            }
        }
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 08 16:53:28 GMT 2021
    - 4.1K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnsh/ShellInvoker.java

     * under the License.
     */
    package org.apache.maven.cling.invoker.mvnsh;
    
    import java.nio.file.Path;
    import java.util.Map;
    import java.util.concurrent.atomic.AtomicReference;
    import java.util.function.Consumer;
    
    import org.apache.maven.api.annotations.Nullable;
    import org.apache.maven.api.cli.InvokerRequest;
    import org.apache.maven.api.services.Lookup;
    import org.apache.maven.cling.invoker.LookupContext;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Thu Oct 16 06:12:36 GMT 2025
    - 10.1K bytes
    - Click Count (0)
  8. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/SplitPackagesAuditTask.java

    import java.util.HashMap;
    import java.util.HashSet;
    import java.util.List;
    import java.util.Map;
    import java.util.Set;
    import java.util.TreeMap;
    import java.util.TreeSet;
    import java.util.function.Consumer;
    import java.util.stream.Collectors;
    
    /**
     * Checks for split packages with dependencies. These are not allowed in a future modularized world.
     */
    public class SplitPackagesAuditTask extends DefaultTask {
    
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 08 22:04:23 GMT 2021
    - 14.2K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

         *
         * @param cb the consumer to customize the search request
         * @param cleanupTime the time taken for the last cleanup operation
         * @return the list of access results ready for processing
         */
        private List<OpenSearchAccessResult> getAccessResultList(final Consumer<SearchRequestBuilder> cb, final long cleanupTime) {
            if (logger.isDebugEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/Service.java

       * {@code A -> B}.
       *
       * @since 9.0 (in 1.0 as {@code com.google.common.base.Service.State})
       */
      enum State {
        /** A service in this state is inactive. It does minimal work and consumes minimal resources. */
        NEW,
    
        /** A service in this state is transitioning to {@link #RUNNING}. */
        STARTING,
    
        /** A service in this state is operational. */
        RUNNING,
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 10.8K bytes
    - Click Count (0)
Back to Top