Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 236 for consumers (0.07 seconds)

  1. android/guava/src/com/google/common/io/CharSource.java

       * @since 33.4.0 (but since 22.0 in the JRE flavor)
       */
      /*
       * We have to rely on users not to call this without library desugaring, as NewApi won't flag
       * Consumer creation.
       */
      @IgnoreJRERequirement
      public void forEachLine(Consumer<? super String> action) throws IOException {
        try (Stream<String> lines = lines()) {
          // The lines should be ordered regardless in most cases, but use forEachOrdered to be sure
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  2. 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 Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Nov 08 08:49:11 GMT 2024
    - 8.4K bytes
    - Click Count (0)
  3. guava/src/com/google/common/io/CharSource.java

    import java.io.UncheckedIOException;
    import java.io.Writer;
    import java.nio.charset.Charset;
    import java.util.ArrayList;
    import java.util.Iterator;
    import java.util.List;
    import java.util.function.Consumer;
    import java.util.stream.Stream;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A readable source of characters, such as a text file. Unlike a {@link Reader}, a {@code
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  4. impl/maven-cli/src/main/java/org/apache/maven/cling/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 Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Feb 06 11:28:05 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt

      private inline fun <T : Any> ResponseBody.consumeSource(
        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)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue May 27 14:51:25 GMT 2025
    - 11.6K bytes
    - Click Count (0)
  6. docs/es/docs/deployment/concepts.md

    Por ejemplo, si tu código carga un modelo de Machine Learning con **1 GB de tamaño**, cuando ejecutas un proceso con tu API, consumirá al menos 1 GB de RAM. Y si inicias **4 procesos** (4 workers), cada uno consumirá 1 GB de RAM. Así que, en total, tu API consumirá **4 GB de RAM**.
    
    Y si tu servidor remoto o máquina virtual solo tiene 3 GB de RAM, intentar cargar más de 4 GB de RAM causará problemas. 🚨
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 16 16:33:45 GMT 2025
    - 20.1K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt

          result.write(this, i)
          // Consume '"'.
          readByte()
          return result.readUtf8()
        }
    
        if (size == i + 1L) return null // Dangling escape.
        result.write(this, i)
        // Consume '\'.
        readByte()
        result.write(this, 1L) // The escaped character.
      }
    }
    
    /**
     * Consumes and returns a non-empty token, terminating at special characters in
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 7.2K bytes
    - Click Count (0)
  8. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

        // Note that this may be be an encoded "end of data" header.
        return DerHeader(tagClass, tag, constructed, length)
      }
    
      /**
       * Consume a header and execute [block], which should consume the entire value described by the
       * header. It is an error to not consume a full value in [block].
       */
      internal inline fun <T> read(
        name: String?,
        block: (DerHeader) -> T,
      ): T {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 10.5K bytes
    - Click Count (0)
  9. docs/pt/docs/deployment/concepts.md

    ### Memória do servidor { #server-memory }
    
    Por exemplo, se seu código carrega um modelo de Machine Learning com **1 GB de tamanho**, quando você executa um processo com sua API, ele consumirá pelo menos 1 GB de RAM. E se você iniciar **4 processos** (4 trabalhadores), cada um consumirá 1 GB de RAM. Então, no total, sua API consumirá **4 GB de RAM**.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Nov 12 16:23:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  10. 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 Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Feb 12 12:31:43 GMT 2025
    - 3K bytes
    - Click Count (0)
Back to Top