Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 1,138 for vals (0.02 seconds)

  1. .github/workflows/update-rbe.yml

            map sigbuild-r2.12-python3.9 2.12-python3.9
            map sigbuild-r2.12-python3.10 2.12-python3.10
            map sigbuild-r2.12-python3.11 2.12-python3.11
            # TF 2.12 + Clang (containers are the same, but env vars in configs.bzl are different)
            map sigbuild-r2.12-clang 2.12-python3.9
            map sigbuild-r2.12-clang-python3.8 2.12-python3.8
            map sigbuild-r2.12-clang-python3.9 2.12-python3.9
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Dec 01 09:57:00 GMT 2025
    - 7.2K bytes
    - Click Count (1)
  2. android-test/src/androidTest/java/okhttp/android/test/SingleAndroidTest.kt

     */
    class SingleAndroidTest {
      private val handshakeCertificates = localhost()
    
      private var client: OkHttpClient =
        OkHttpClient
          .Builder()
          .sslSocketFactory(
            handshakeCertificates.sslSocketFactory(),
            handshakeCertificates.trustManager,
          ).connectionPool(ConnectionPool(0, 1, TimeUnit.SECONDS))
          .build()
    
      private val server =
        MockWebServer()
    
      @Test
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Nov 21 12:33:41 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  3. .teamcity/src/main/kotlin/model/BucketExtensions.kt

            // In this case, we simply put the elements into these buckets evenly.
            return list.chunked(list.size / expectedBucketNumber, smallElementAggregateFunction)
        }
    
        val largestElement = list.removeFirst()!!
    
        val largestElementSize = toIntFunction(largestElement)
    
        if (largestElementSize >= roughSizeOfEachBucket) {
            var bucketNumberOfFirstElement =
                determineBucketNumberForLargeElment(
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Feb 12 09:12:03 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  4. okhttp-dnsoverhttps/README.md

    ```
    
    ### Usage
    
    ```
      val appCache = Cache(File("cacheDir", "okhttpcache"), 10 * 1024 * 1024)
      val bootstrapClient = OkHttpClient.Builder().cache(appCache).build()
    
      val dns = DnsOverHttps.Builder().client(bootstrapClient)
        .url("https://dns.google/dns-query".toHttpUrl())
        .bootstrapDnsHosts(InetAddress.getByName("8.8.4.4"), InetAddress.getByName("8.8.8.8"))
        .build()
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Oct 30 21:39:59 GMT 2025
    - 739 bytes
    - Click Count (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/EventListenerRelay.kt

     * a stale [EventListener] in a field or local variable.
     */
    class EventListenerRelay(
      val call: Call,
      val eventRecorder: EventRecorder,
    ) {
      private val eventListenerAdapter =
        EventListenerAdapter()
          .apply {
            listeners += ::onEvent
          }
    
      val eventListener: EventListener
        get() = eventListenerAdapter
    
      var eventCount = 0
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt

          )
        }
      }
    
      @Test
      fun byteStringEmpty() {
        val body = body("")
        assertThat(body.byteString()).isEqualTo(ByteString.EMPTY)
      }
    
      @Test
      fun byteStringSeesBom() {
        val body = body("efbbbf68656c6c6f")
        val actual = body.byteString()
        val expected: ByteString = "efbbbf68656c6c6f".decodeHex()
        assertThat(actual).isEqualTo(expected)
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 12.4K bytes
    - Click Count (0)
  7. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

            .build(),
        )
        val startNanos = System.nanoTime()
        val connection = server.url("/").toUrl().openConnection()
        connection.doOutput = true
        connection.getOutputStream().write("ABCDEF".toByteArray(UTF_8))
        val inputStream = connection.getInputStream()
        assertThat(inputStream.read()).isEqualTo(-1)
        val elapsedNanos = System.nanoTime() - startNanos
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/SequentialExchangeFinder.kt

    internal class SequentialExchangeFinder(
      override val routePlanner: RoutePlanner,
    ) : ExchangeFinder {
      override fun find(): RealConnection {
        var firstException: IOException? = null
        while (true) {
          if (routePlanner.isCanceled()) throw IOException("Canceled")
    
          try {
            val plan = routePlanner.plan()
    
            if (!plan.isReady) {
              val tcpConnectResult = plan.connectTcp()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  9. build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepository.kt

                }
            }
    
        private
        val JApiClass.sourceFilePath: String
            get() = if (isKotlin) kotlinSourceFilePath else javaSourceFilePath
    
        private
        val JApiClass.javaSourceFilePath: String
            get() = fullyQualifiedName
                .replace(".", "/")
                .replace(innerClassesPartRegex, "") + ".java"
    
        private
        val innerClassesPartRegex =
            "\\$.*".toRegex()
    
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Wed Dec 24 14:15:15 GMT 2025
    - 3.8K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

      private class TestStreams(
        private val taskFaker: TaskFaker,
        private val delegate: Socket,
        private val client: Boolean,
      ) : BufferedSocket {
        private val name = if (client) "client" else "server"
        val listener = WebSocketRecorder(name)
        var webSocket: RealWebSocket? = null
        var sourceClosed = false
        var sinkClosed = false
        val closed: Boolean
          get() = sourceClosed && sinkClosed
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 18.7K bytes
    - Click Count (0)
Back to Top