Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 75 for chan (0.16 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-brotli/src/main/kotlin/okhttp3/brotli/BrotliInterceptor.kt

      override fun intercept(chain: Interceptor.Chain): Response {
        return if (chain.request().header("Accept-Encoding") == null) {
          val request =
            chain.request().newBuilder()
              .header("Accept-Encoding", "br,gzip")
              .build()
    
          val response = chain.proceed(request)
    
          uncompress(response)
        } else {
          chain.proceed(chain.request())
        }
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 1.3K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt

            }
          }
    
        // Get a reference to the connection so we can violently destroy it.
        val connection = AtomicReference<Connection?>()
        val client1 =
          client.newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                connection.set(chain!!.connection())
                chain.proceed(chain.request())
              },
            )
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 18.7K bytes
    - Viewed (0)
Back to top