Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 684 for consume (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top