- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 298 for consumers (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)