Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for Consuming (0.05 sec)

  1. samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

              // Produced ClientHello handshake message
              // Consuming ServerHello handshake message
              // Consuming server Certificate handshake message
              // Consuming server CertificateStatus handshake message
              // Found trusted certificate
              // Consuming ECDH ServerKeyExchange handshake message
              // Consuming ServerHelloDone handshake message
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat May 10 11:15:14 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb1/netbios/SocketInputStreamTest.java

            // Read the three data bytes
            assertEquals(1, sis.read());
            assertEquals(2, sis.read());
            assertEquals(3, sis.read());
    
            // After consuming all data, trying to read again will attempt to read
            // another packet header, but since there's no more data, it will throw IOException
            assertThrows(IOException.class, () -> sis.read());
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt

      }
    
      @Test
      fun trailersWithServerTruncatedResponseHttp2() {
        trailersWithServerTruncatedResponse(Protocol.HTTP_2)
      }
    
      /**
       * If the server closes the connection while the client is consuming the response body, attempts
       * to peek or read the trailers should throw.
       */
      private fun trailersWithServerTruncatedResponse(protocol: Protocol) {
        val responseBody = "a".repeat(OKHTTP_CLIENT_WINDOW_SIZE)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 18K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/JsseDebugLogging.kt

              message.startsWith("System property ") -> Type.Setup
              message.startsWith("Reload ") -> Type.Setup
              message == "No session to resume." -> Type.Handshake
              message.startsWith("Consuming ") -> Type.Handshake
              message.startsWith("Produced ") -> Type.Handshake
              message.startsWith("Negotiated ") -> Type.Handshake
              message.startsWith("Found resumable session") -> Type.Handshake
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt

     *     }
     *   }
     *
     *   public void onFailure(Call call, IOException e) {
     *   ... // Handle the failure.
     *   }
     * });
     * ```
     *
     * These examples will not work if you're consuming the response body on another thread. In such
     * cases the consuming thread must call [close] when it has finished reading the response
     * body.
     *
     * ### The response body can be consumed only once.
     *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:51:25 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/NetServerFileEntryAdapterIteratorTest.java

            assertNotNull(r2, "Second adapted resource must not be null");
            assertTrue(r2.getName().endsWith("/"), "Name should end with '/'");
    
            assertFalse(itr.hasNext(), "No more elements after consuming two");
        }
    
        @ParameterizedTest
        @NullAndEmptySource
        @DisplayName("Invalid names are skipped; next valid is returned")
        void skipsMalformedNames_thenReturnsValid(String badName) throws Exception {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  7. docs/en/docs/tutorial/request-files.md

        * A file stored in memory up to a maximum size limit, and after passing this limit it will be stored in disk.
    * This means that it will work well for large files like images, videos, large binaries, etc. without consuming all the memory.
    * You can get metadata from the uploaded file.
    * It has a <a href="https://docs.python.org/3/glossary.html#term-file-like-object" class="external-link" target="_blank">file-like</a> `async` interface.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/util/transport/Transport.java

         * @throws IOException if an I/O error occurs
         */
        protected abstract void makeKey(Request request) throws IOException;
    
        /**
         * Reads and returns the key of the next message without consuming it.
         *
         * @return the request key of the next message
         * @throws IOException if an I/O error occurs
         */
        protected abstract Request peekKey() throws IOException;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/DirFileEntryEnumIteratorBaseTest.java

            verify(nameFilter, atLeast(1)).accept(eq(parent), nameCaptor.capture());
            assertTrue(nameCaptor.getAllValues().contains(acceptedName));
    
            // After consuming accepted name, iterator should be exhausted and closed
            assertFalse(it.hasNext());
            verify(tree, times(1)).release();
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Response.kt

       * trailers are available to read.
       *
       * It is not safe to call this concurrently with code that is processing the response body. If you
       * call this without consuming the complete response body, any remaining bytes in the response
       * body will be discarded before trailers are returned.
       *
       * If [Call.cancel] is called while this is blocking, this call will immediately throw.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 28 14:39:28 UTC 2025
    - 18.1K bytes
    - Viewed (0)
Back to top