- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 684 for consume (0.1 sec)
-
guava/src/com/google/common/collect/Streams.java
Stream<A> streamA, Stream<B> streamB, BiConsumer<? super A, ? super B> consumer) { checkNotNull(consumer); if (streamA.isParallel() || streamB.isParallel()) { zip(streamA, streamB, TemporaryPair::new).forEach(pair -> consumer.accept(pair.a, pair.b)); } else { Iterator<A> iterA = streamA.iterator(); Iterator<B> iterB = streamB.iterator();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 36.8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Listener.java
import org.apache.maven.api.annotations.Consumer; import org.apache.maven.api.annotations.Experimental; import org.apache.maven.api.annotations.Nonnull; /** * A listener for session events. * TODO: open this to other events like similar to {@code org.apache.maven.eventspy.EventSpy} * * @since 4.0.0 */ @Experimental @FunctionalInterface @Consumer public interface Listener {
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Mar 23 05:29:39 UTC 2023 - 1.2K bytes - Viewed (0) -
guava/src/com/google/common/collect/ImmutableMapKeySet.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import java.io.Serializable; import java.util.Spliterator; import java.util.function.Consumer; import javax.annotation.CheckForNull; /** * {@code keySet()} implementation for {@link ImmutableMap}. * * @author Jesse Wilson * @author Kevin Bourrillion */ @GwtCompatible(emulated = true)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Nov 30 21:54:06 UTC 2023 - 2.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/backup/AdminBackupAction.java
import java.time.format.DateTimeFormatter; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Consumer; import java.util.stream.Collectors; import org.apache.commons.text.StringEscapeUtils; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger;
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sat Oct 12 01:54:46 UTC 2024 - 28.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-ResponseBodyCommon.kt
internal inline fun <T : Any> ResponseBody.commonConsumeSource( consumer: (BufferedSource) -> T, sizeMapper: (T) -> Int, ): T { val contentLength = contentLength() if (contentLength > Int.MAX_VALUE) { throw IOException("Cannot buffer entire body for content length: $contentLength") } val bytes = source().use(consumer) val size = sizeMapper(bytes)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/beans/util/BeanUtil.java
import static org.codelibs.core.collection.CollectionsUtil.newLinkedHashMap; import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull; import java.util.Map; import java.util.Map.Entry; import java.util.function.Consumer; import org.codelibs.core.beans.BeanDesc; import org.codelibs.core.beans.PropertyDesc; import org.codelibs.core.beans.factory.BeanDescFactory; import org.codelibs.core.lang.ClassUtil; /**
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 21.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.27.md
[registry.k8s.io/conformance:v1.27.11](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/conformance) | [amd64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/conformance-amd64), [arm64](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/conformance-arm64), [ppc64le](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/conformance-ppc64le), [s390x](https://console.cloud.google.com/gcr/images/k8s-artifacts-prod/us/conformance-s390x)...
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Jul 17 07:48:22 UTC 2024 - 466.3K bytes - Viewed (1) -
src/main/java/org/codelibs/fess/helper/SearchHelper.java
throw new SearchEngineClientException("Failed to update doc " + id, e); } } public boolean bulkUpdate(final Consumer<BulkRequestBuilder> consumer) { final BulkRequestBuilder builder = ComponentUtil.getSearchEngineClient().prepareBulk(); consumer.accept(builder); try { final BulkResponse response = builder.execute().get(); if (response.hasFailures()) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 19.1K bytes - Viewed (0) -
cmd/consolelogger.go
console *console.Target nodeName string logBuf *ring.Ring } // NewConsoleLogger - creates new HTTPConsoleLoggerSys with all nodes subscribed to // the console logging pub sub system func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys { return &HTTPConsoleLoggerSys{ pubsub: pubsub.New[log.Info, madmin.LogMask](8), console: console.New(w),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessBaseAction.java
} protected static void copyBeanToBean(final Object src, final Object dest, final Consumer<CopyOptions> option) { BeanUtil.copyBeanToBean(src, dest, option); } protected static void copyMapToBean(final Map<String, ? extends Object> src, final Object dest, final Consumer<CopyOptions> option) { BeanUtil.copyMapToBean(src, dest, option); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 9.3K bytes - Viewed (0)