Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 64 for chan (0.18 sec)

  1. okhttp/src/main/kotlin/okhttp3/Interceptor.kt

         *     chain.proceed(chain.request())
         * }
         * ```
         */
        inline operator fun invoke(crossinline block: (chain: Chain) -> Response): Interceptor = Interceptor { block(it) }
      }
    
      interface Chain {
        fun request(): Request
    
        @Throws(IOException::class)
        fun proceed(request: Request): Response
    
        /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.5K bytes
    - Viewed (0)
  2. mockwebserver/README.md

      HttpUrl baseUrl = server.url("/v1/chat/");
    
      // Exercise your application code, which should make those HTTP requests.
      // Responses are returned in the same order that they are enqueued.
      Chat chat = new Chat(baseUrl);
    
      chat.loadMore();
      assertEquals("hello, world!", chat.messages());
    
      chat.loadMore();
      chat.loadMore();
      assertEquals(""
          + "hello, world!\n"
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 17 15:34:10 GMT 2023
    - 5K bytes
    - Viewed (1)
  3. okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

        )
        fun getLevel(): Level = level
    
        @Throws(IOException::class)
        override fun intercept(chain: Interceptor.Chain): Response {
          val level = this.level
    
          val request = chain.request()
          if (level == Level.NONE) {
            return chain.proceed(request)
          }
    
          val logBody = level == Level.BODY
          val logHeaders = logBody || level == Level.HEADERS
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 09:14:38 GMT 2024
    - 11.2K bytes
    - Viewed (1)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

              connectionPool = connectionPool,
              readTimeoutMillis = client.readTimeoutMillis,
              writeTimeoutMillis = client.writeTimeoutMillis,
              socketConnectTimeoutMillis = chain.connectTimeoutMillis,
              socketReadTimeoutMillis = chain.readTimeoutMillis,
              pingIntervalMillis = client.pingIntervalMillis,
              retryOnConnectionFailure = client.retryOnConnectionFailure,
              fastFallback = client.fastFallback,
    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)
  5. okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

       */
      private fun assertWildcardRule(rule: String) {
        check(rule.startsWith(WILDCARD_CHAR)) {
          """Wildcard Assertion Failure: '$rule'
    A wildcard rule was added with a wildcard that is not in leftmost position! We'll need to change the ${PublicSuffixDatabase::class.java.name} to handle this."""
        }
        check(rule.indexOf(WILDCARD_CHAR, 1) == -1) {
          """Wildcard Assertion Failure: '$rule'
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:24:38 GMT 2024
    - 6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

        client: OkHttpClient,
        chain: RealInterceptorChain,
      ): ExchangeCodec {
        val socket = this.socket!!
        val source = this.source!!
        val sink = this.sink!!
        val http2Connection = this.http2Connection
    
        return if (http2Connection != null) {
          Http2ExchangeCodec(client, this, chain, http2Connection)
        } else {
          socket.soTimeout = chain.readTimeoutMillis()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  7. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

        private fun createInsecureTrustManager(): X509TrustManager =
          object : X509TrustManager {
            override fun checkClientTrusted(
              chain: Array<X509Certificate>,
              authType: String,
            ) {}
    
            override fun checkServerTrusted(
              chain: Array<X509Certificate>,
              authType: String,
            ) {}
    
            override fun getAcceptedIssuers(): Array<X509Certificate> = arrayOf()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.7K bytes
    - Viewed (1)
  8. okhttp/src/test/java/okhttp3/URLConnectionTest.kt

       *   .build();
       * ```
       */
      internal class LegacyRedirectInterceptor : Interceptor {
        override fun intercept(chain: Interceptor.Chain): Response {
          val response = chain.proceed(chain.request())
          val code = response.code
          if (code != HTTP_TEMP_REDIRECT && code != HTTP_PERM_REDIRECT) return response
          val method = response.request.method
    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)
  9. okhttp/src/test/java/okhttp3/CallTest.kt

        client =
          client.newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain ->
                try {
                  chain.proceed(chain.request())
                  throw AssertionError()
                } catch (expected: IOException) {
                  chain.proceed(chain.request())
                }
              },
            )
            .build()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/HeadersTest.kt

          assertThat(expected.message)
            .isEqualTo("Unexpected char 0xe9 at 1 in header name: héader1")
        }
      }
    
      @Test fun builderRejectsUnicodeInHeaderValue() {
        assertFailsWith<IllegalArgumentException> {
          Headers.Builder().add("header1", "valué1")
        }.also { expected ->
          assertThat(expected.message)
            .isEqualTo("Unexpected char 0xe9 at 4 in header1 value: valué1")
        }
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8.6K bytes
    - Viewed (0)
Back to top