Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 236 for consumers (0.07 seconds)

  1. docs/features/events.md

    System.out.println("REQUEST 1 (new connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    
    System.out.println("REQUEST 2 (pooled connection)");
    try (Response response = client.newCall(request).execute()) {
      // Consume and discard the response body.
      response.body().source().readByteString();
    }
    ```
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 7.7K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

    import okhttp3.internal.http.parseChallenges
    import okio.Buffer
    import okio.Socket
    
    /**
     * An HTTP response. Instances of this class are not immutable: the response body is a one-shot
     * value that may be consumed only once and then closed. All other properties are immutable.
     *
     * This class implements [Closeable]. Closing it simply closes its response body. See
     * [ResponseBody] for an explanation and examples.
     */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 28 14:39:28 GMT 2025
    - 18.1K bytes
    - Click Count (0)
  3. guava/src/com/google/common/collect/Cut.java

        return false;
      }
    
      // Prevent "missing hashCode" warning by explicitly forcing subclasses implement it
      @Override
      public abstract int hashCode();
    
      /*
       * The implementation neither produces nor consumes any non-null instance of type C, so
       * casting the type parameter is safe.
       */
      @SuppressWarnings("unchecked")
      static <C extends Comparable> Cut<C> belowAll() {
        return (Cut<C>) BelowAll.INSTANCE;
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Callback.kt

       * proceed to read the response body with [Response.body]. The response is still live until its
       * response body is [closed][ResponseBody]. The recipient of the callback may consume the response
       * body on another thread.
       *
       * Note that transport-layer success (receiving a HTTP response code, headers and body) does not
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  5. compat/maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java

                final CommandLine commandLine, final String option, final Consumer<Boolean> setting) {
            if (commandLine.hasOption(option)) {
                setting.accept(false);
            }
        }
    
        private void disableOnPresentOption(
                final CommandLine commandLine, final char option, final Consumer<Boolean> setting) {
            disableOnPresentOption(commandLine, String.valueOf(option), setting);
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 78.1K bytes
    - Click Count (0)
  6. samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java

        try (Response response = client.newCall(request).execute()) {
          // Consume and discard the response body.
          response.body().source().readByteString();
        }
    
        System.out.println("REQUEST 2 (pooled connection)");
        try (Response response = client.newCall(request).execute()) {
          // Consume and discard the response body.
          response.body().source().readByteString();
        }
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 16 23:20:49 GMT 2020
    - 5.3K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/Punycode.kt

        // appendCodePoint(). The Punycode algorithm processes code points in increasing code-point
        // order, not in increasing index order.
        val codePoints = mutableListOf<Int>()
    
        // consume all code points before the last delimiter (if there is one)
        //  and copy them to output, fail on any non-basic code point
        val lastDelimiter = string.lastIndexOf('-', limit)
        if (lastDelimiter >= pos) {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 8.5K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/MavenInvoker.java

    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.util.ArrayList;
    import java.util.LinkedHashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Optional;
    import java.util.function.Consumer;
    import java.util.regex.Matcher;
    import java.util.regex.Pattern;
    import java.util.stream.Collectors;
    
    import org.apache.maven.InternalErrorException;
    import org.apache.maven.Maven;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Sep 11 17:20:46 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  9. .github/DISCUSSION_TEMPLATE/questions.yml

            Thanks for your interest in FastAPI! 🚀
    
            Please follow these instructions, fill every question, and do every step. 🙏
    
            I'm asking this because answering questions and solving problems in GitHub is what consumes most of the time.
    
            I end up not being able to add new features, fix bugs, review pull requests, etc. as fast as I wish because I have to spend too much time handling questions.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Thu Aug 03 15:59:41 GMT 2023
    - 5.8K bytes
    - Click Count (0)
  10. CHANGELOG/CHANGELOG-1.18.md

    - consumers of the 'certificatesigningrequests/approval' API must now have permission to 'approve' CSRs for the specific signer requested by the CSR. More information on the new signerName field and the required authorization can be found at https://kuberne...
    Created: Fri Dec 26 09:05:12 GMT 2025
    - Last Modified: Wed Jun 16 17:18:28 GMT 2021
    - 373.2K bytes
    - Click Count (0)
Back to Top