Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 278 for consumer (0.14 seconds)

  1. api/maven-api-annotations/src/main/java/org/apache/maven/api/annotations/Consumer.java

     * <p>
     * A type can be marked {@link Consumer} or {@link Provider} but not both. A type is assumed to be
     * {@link Consumer} if it is not marked either {@link Consumer} or {@link Provider}.
     * <p>
     * A package can be marked {@link Consumer}. In this case, all types in the package are considered
     * to be a provider type regardless of whether they are marked {@link Consumer} or {@link Provider}.
     *
     * @see Provider
     * @since 4.0.0
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Dec 10 21:43:27 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/ConsumerPomArtifactTransformer.java

                }
                for (Artifact consumer : consumers) {
                    result.remove(consumer);
                    // Replace the consumer POM as the main POM (no classifier)
                    result.add(new DefaultArtifact(
                            consumer.getGroupId(),
                            consumer.getArtifactId(),
                            "",
                            consumer.getExtension(),
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Mar 04 19:49:40 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  3. impl/maven-core/src/main/java/org/apache/maven/logging/LoggingOutputStream.java

    import java.io.PrintStream;
    import java.util.function.Consumer;
    
    public class LoggingOutputStream extends FilterOutputStream {
    
        static final byte[] LINE_SEP = System.lineSeparator().getBytes();
    
        final EolBaos buf;
        final Consumer<String> consumer;
    
        public LoggingOutputStream(Consumer<String> consumer) {
            this(new EolBaos(), consumer);
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Feb 12 12:31:43 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java

            private final TransferEvent event;
    
            private Exchange(TransferEvent event) {
                this.event = event;
            }
    
            public void process(Consumer<TransferEvent> consumer) {
                consumer.accept(event);
            }
    
            public void waitForProcessed() throws InterruptedException {
                // nothing, is async
            }
        }
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Nov 08 08:49:11 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java

         * @param consumer The callback.
         * @return The promise.
         */
        public Promise then(final Consumer<RESPONSE> consumer) {
            return promise.then(consumer);
        }
    
        /**
         * Registers a callback to be executed when the computation fails.
         * @param consumer The callback.
         * @return The promise.
         */
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Fri Jul 04 14:00:23 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb/DosErrorTest.java

        }
    
        @Test
        @DisplayName("Interaction: consumer is invoked for each found mapping")
        void interactionWithConsumerIsAsExpected() {
            // Arrange: choose a small set of known DOS codes
            List<Integer> inputs = Arrays.asList(0x00000000, 0x00050001, 0x007b0001, 0x0BADF00D);
            @SuppressWarnings("unchecked")
            BiConsumer<Integer, Integer> consumer = mock(BiConsumer.class);
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/ConfiguredGoalSupport.java

                    response.getReport().entrySet()) {
                Consumer<String> consumer = s ->
                        context.logger.info(messageBuilderFactory.builder().info(s).build());
                if (entry.getKey() == SecDispatcher.ValidationResponse.Level.ERROR) {
                    consumer = s -> context.logger.error(
                            messageBuilderFactory.builder().error(s).build());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  8. src/test/java/jcifs/smb/RequestParamTest.java

            // Arrange: pick a value and a mocked consumer
            RequestParam rp = RequestParam.NO_RETRY;
    
            // Act: pass to the collaborator
            consumer.accept(rp);
    
            // Assert: interaction happened exactly once with correct argument; no other calls
            verify(consumer, times(1)).accept(RequestParam.NO_RETRY);
            verifyNoMoreInteractions(consumer);
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  9. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/artifact/MavenArtifactProperties.java

         * consumer project.
         * <p>
         * Note: This property is about "build path", whatever it means in the scope of the consumer project. It is NOT
         * about Java classpath or anything alike. How artifact is being consumed depends heavily on the consumer project.
         * Resolver is and will remain agnostic of consumer project use cases.
         */
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Mar 28 11:22:05 GMT 2026
    - 2.9K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/IndexedImmutableSet.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
      @GwtIncompatible
      int copyIntoArray(@Nullable Object[] dst, int offset) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.6K bytes
    - Click Count (0)
Back to Top