Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for chan (0.17 sec)

  1. okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt

        client =
          client.newBuilder()
            .addNetworkInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                val request =
                  chain!!.request().newBuilder()
                    .header("Host", "privateobject.com")
                    .build()
                chain.proceed(request)
              },
            )
            .build()
        server.enqueue(MockResponse())
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 11 22:09:35 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/EventListenerTest.kt

        client =
          client.newBuilder()
            .addInterceptor(
              Interceptor { chain: Interceptor.Chain? ->
                chain!!.proceed(chain.request())
                  .use { a -> assertThat(a.body.string()).isEqualTo("a") }
                chain.proceed(chain.request())
              },
            )
            .build()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 56.9K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt

        inline fun addInterceptor(crossinline block: (chain: Interceptor.Chain) -> Response) =
          addInterceptor(Interceptor { chain -> block(chain) })
    
        /**
         * Returns a modifiable list of interceptors that observe a single network request and response.
         * These interceptors must call [Interceptor.Chain.proceed] exactly once: it is an error for a
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 06 04:21:33 GMT 2024
    - 52K bytes
    - Viewed (0)
  4. analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCallResolver.kt

            get() {
                if (this !is FirNamedReference) return null
    
                // In most cases, we can get the callee name from the callee's candidate symbols. However, there is at least one case where we
                // cannot do so:
                // ```
                // fun x(c: Char) {}
                // fun call(x: kotlin.Int) {
                //   operator fun Int.invoke(a: Int) {}
    Plain Text
    - Registered: Fri Apr 26 08:18:10 GMT 2024
    - Last Modified: Thu Apr 25 18:05:58 GMT 2024
    - 70.8K bytes
    - Viewed (1)
  5. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

          return URL(url)
        } catch (e: MalformedURLException) {
          throw RuntimeException(e) // Unexpected!
        }
      }
    
      /**
       * Returns this URL as a [java.net.URI][URI]. Because `URI` is more strict than this class, the
       * returned URI may be semantically different from this URL:
       *
       *  * Characters forbidden by URI like `[` and `|` will be escaped.
       *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 63.5K bytes
    - Viewed (1)
  6. docs/bucket/notifications/README.md

    goes offline and replays it when the broker comes back online. The event store can be configured by setting the directory path in `queue_dir` field and the maximum limit of events in the queue_dir in `queue_limit` field. For eg, the `queue_dir` can be `/home/events` and `queue_limit` can be `1000`. By default, the `queue_limit` is set to 100000.
    
    If Elasticsearch has authentication enabled, the credentials can be supplied to MinIO via the `url` parameter formatted as `PROTO://USERNAME:P...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  7. okhttp/api/okhttp.api

    	public abstract fun withConnectTimeout (ILjava/util/concurrent/TimeUnit;)Lokhttp3/Interceptor$Chain;
    	public abstract fun withReadTimeout (ILjava/util/concurrent/TimeUnit;)Lokhttp3/Interceptor$Chain;
    	public abstract fun withWriteTimeout (ILjava/util/concurrent/TimeUnit;)Lokhttp3/Interceptor$Chain;
    	public abstract fun writeTimeoutMillis ()I
    }
    
    public final class okhttp3/Interceptor$Companion {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:41:01 GMT 2024
    - 70.2K bytes
    - Viewed (0)
Back to top