Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 51 for causal (0.14 sec)

  1. docs/changelogs/changelog_4x.md

        The new behavior strips invalid characters like `"` and `{` from the hostname before converting.
    
     *  Fix: Undo a performance regression introduced in OkHttp 4.0 caused by differences in behavior
        between Kotlin's `assert()` and Java's `assert()`. (Kotlin always evaluates the argument; Java
        only does when assertions are enabled.)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 17 13:25:31 GMT 2024
    - 25.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http/RealResponseBody.kt

    import okhttp3.ResponseBody
    import okio.BufferedSource
    
    class RealResponseBody(
      /**
       * Use a string to avoid parsing the content type until needed. This also defers problems caused
       * by malformed content types.
       */
      private val contentTypeString: String?,
      private val contentLength: Long,
      private val source: BufferedSource,
    ) : ResponseBody() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

          }
        }
    
        return null
      }
    
      private fun <E : IOException?> timeoutExit(cause: E): E {
        if (timeoutEarlyExit) return cause
        if (!timeout.exit()) return cause
    
        val e = InterruptedIOException("timeout")
        if (cause != null) e.initCause(cause)
        @Suppress("UNCHECKED_CAST") // E is either IOException or IOException?
        return e as E
      }
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 17.9K bytes
    - Viewed (2)
  4. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

      fun sendFrame(): Http2Writer {
        outFrames.add(OutFrame(frameCount++, bytesOut.size, false))
        return writer
      }
    
      /**
       * Shortens the last frame from its original length to `length`. This will cause the peer to
       * close the socket as soon as this frame has been written; otherwise the peer stays open until
       * explicitly closed.
       */
      fun truncateLastFrame(length: Int): Http2Writer {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt

      private val data = Buffer()
      private val random = Random(0)
    
      /**
       * Check all data as verified inside of the test. We do this in an AfterEachCallback so that
       * exceptions thrown from the test do not cause this check to fail.
       */
      @RegisterExtension
      val noDataLeftBehind =
        AfterEachCallback { context: ExtensionContext ->
          if (context.executionException.isPresent) return@AfterEachCallback
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt

        // The WHATWG Host parsing rules accepts some character codes which are invalid by
        // definition for OkHttp's host header checks (and the WHATWG Host syntax definition). Here
        // we rule out characters that would cause problems in host headers.
        if (c <= '\u001f' || c >= '\u007f') {
          return true
        }
        // Check for the characters mentioned in the WHATWG Host parsing spec:
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 11.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

        )
        inputStream.close()
        assertContent("ABCDEFGHIJKLMNOPQRSTUVWXYZ", getResponse(newRequest("/")))
      }
    
      /**
       * We've had a bug where we forget the HTTP response when we see response code 401. This causes a
       * new HTTP request to be issued for every call into the URLConnection.
       */
      @Test
      fun unauthorizedResponseHandling() {
        val mockResponse =
          MockResponse(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 131.7K bytes
    - Viewed (0)
  8. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

        try {
          dns.lookup("google.com")
          fail<Any>()
        } catch (ioe: IOException) {
          assertThat(ioe.message).isEqualTo("google.com")
          val cause = ioe.cause!!
          assertThat(cause).isInstanceOf<IOException>()
          assertThat(cause).hasMessage("response size exceeds limit (65536 bytes): 65537 bytes")
        }
      }
    
      @Test
      fun failOnBadResponse() {
        server.enqueue(dnsResponse("00"))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 11K bytes
    - Viewed (0)
  9. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

          assertEquals(200, response.code)
          assertEquals("h3", response.negotiatedProtocol)
          assertTrue(response.content.contains("Disallow"))
        } catch (ee: ExecutionException) {
          throw ee.cause?.cause ?: ee.cause!!
        }
      }
    
      data class Response(
        val code: Int,
        val negotiatedProtocol: String,
        val content: String,
      )
    
      private fun execute(
        engine: HttpEngine,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 24 13:19:43 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

       *
       * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it.
       */
      object ShutdownInputAtEnd : SocketPolicy
    
      /**
       * Shutdown the socket output after sending the response. For testing bad behavior.
       *
       * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it.
       */
      object ShutdownOutputAtEnd : SocketPolicy
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 4.6K bytes
    - Viewed (0)
Back to top