Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 659 for consumer (0.05 seconds)

  1. android/guava/src/com/google/common/base/Converter.java

       *     unimplement<i>able</i> (for example, consider a {@code Converter<Chicken, ChickenNugget>}),
       *     then this is not logically a {@code Converter} at all, and should just implement {@link
       *     Function}.
       */
      @ForOverride
      protected abstract A doBackward(B b);
    
      // API (consumer-side) methods
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jun 18 21:43:06 GMT 2025
    - 22.8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/Maps.java

              return entrySpliterator();
            }
    
            @Override
            public void forEach(Consumer<? super Entry<K, V>> action) {
              forEachEntry(action);
            }
          };
        }
    
        void forEachEntry(Consumer<? super Entry<K, V>> action) {
          entryIterator().forEachRemaining(action);
        }
    
        @Override
        public void clear() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 163.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/io/ByteSource.java

          closer.close();
        }
      }
    
      /**
       * Reads the contents of this byte source using the given {@code processor} to process bytes as
       * they are read. Stops when all bytes have been read or the consumer returns {@code false}.
       * Returns the result produced by the processor.
       *
       * @throws IOException if an I/O error occurs while reading from this source or if {@code
       *     processor} throws an {@code IOException}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc4HttpClient.java

            }
    
            formSchemeList.forEach(p -> {
                final Hc4FormScheme scheme = p.getFirst();
                final Credentials credentials = p.getSecond();
                scheme.authenticate(credentials, (request, consumer) -> {
    
                    // request header
                    for (final Header header : requestHeaderList) {
                        request.addHeader(header);
                    }
    
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Fri Jan 09 23:46:52 GMT 2026
    - 54.4K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/ImmutableSortedMap.java

    import java.util.Map;
    import java.util.NavigableMap;
    import java.util.SortedMap;
    import java.util.Spliterator;
    import java.util.TreeMap;
    import java.util.function.BiConsumer;
    import java.util.function.BinaryOperator;
    import java.util.function.Consumer;
    import java.util.function.Function;
    import java.util.stream.Collector;
    import java.util.stream.Collectors;
    import org.jspecify.annotations.Nullable;
    
    /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 08 18:10:02 GMT 2026
    - 52.1K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/helper/QueryHelperTest.java

        }
    
        @Test
        public void test_buildBaseQuery_invalidQuery() {
            try {
                queryHelper.buildBaseQuery(new QueryContext("field:[invalid", true), ctx -> {
                    // Empty context consumer
                });
                // Some invalid queries might be handled gracefully
            } catch (InvalidQueryException e) {
                // This is expected for malformed queries
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 53.2K bytes
    - Click Count (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc5HttpClient.java

                        consumer.accept(response, httpEntity);
                    } catch (final Exception e) {
                        logger.warn("Failed to authenticate with form-based authentication: scheme={}, url={}", scheme, request.getRequestUri(),
                                e);
                    } finally {
                        try {
                            EntityUtils.consume(httpEntity);
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sat Jan 31 12:23:29 GMT 2026
    - 62.2K bytes
    - Click Count (0)
  8. tensorflow/c/c_api.h

                                                          TF_Status* status);
    
    // In this code:
    //   TF_Output producer = TF_OperationInput(consumer);
    // There is an edge from producer.oper's output (given by
    // producer.index) to consumer.oper's input (given by consumer.index).
    TF_CAPI_EXPORT extern TF_Output TF_OperationInput(TF_Input oper_in);
    
    // Get list of all inputs of a specific operation.  `inputs` must point to
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 26 21:08:15 GMT 2023
    - 82.3K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/Synchronized.java

    import java.util.RandomAccess;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.Spliterator;
    import java.util.function.BiConsumer;
    import java.util.function.BiFunction;
    import java.util.function.Consumer;
    import java.util.function.Function;
    import java.util.function.Predicate;
    import java.util.function.UnaryOperator;
    import java.util.stream.Stream;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Aug 08 15:11:10 GMT 2025
    - 56.9K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/ElasticsearchJavaPlugin.java

    import org.gradle.language.base.plugins.LifecycleBasePlugin;
    
    import java.io.File;
    import java.util.List;
    import java.util.Map;
    import java.util.Objects;
    import java.util.function.Consumer;
    import java.util.stream.Stream;
    
    import static org.elasticsearch.gradle.internal.conventions.util.Util.toStringable;
    
    /**
     * A wrapper around Gradle's Java plugin that applies our
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Mon Sep 27 16:04:42 GMT 2021
    - 7.3K bytes
    - Click Count (0)
Back to Top