Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for leash (0.12 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteSelector.kt

      private val postponedRoutes = mutableListOf<Route>()
    
      init {
        resetNextProxy(address.url, address.proxy)
      }
    
      /**
       * Returns true if there's another set of routes to attempt. Every address has at least one route.
       */
      operator fun hasNext(): Boolean = hasNextProxy() || postponedRoutes.isNotEmpty()
    
      @Throws(IOException::class)
      operator fun next(): Selection {
        if (!hasNext()) throw NoSuchElementException()
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Mar 06 17:33:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/MultipartBodyTest.kt

      fun onePartRequired() {
        assertFailsWith<IllegalStateException> {
          MultipartBody.Builder().build()
        }.also { expected ->
          assertThat(expected.message)
            .isEqualTo("Multipart body must have at least one part.")
        }
      }
    
      @Test
      fun singlePart() {
        val expected =
          """
          |--123
          |
          |Hello, World!
          |--123--
          |
          """.trimMargin().replace("\n", "\r\n")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  3. gradle/wrapper/gradle-wrapper.jar

    part of its distribution, then any Derivative Works that You distribute must include a readable copy of the attribution notices contained within such NOTICE file, excluding those notices that do not pertain to any part of the Derivative Works, in at least one of the following places: within a NOTICE text file distributed as part of the Derivative Works; within the Source form or documentation, if provided along with the Derivative Works; or, within a display generated by the Derivative Works, if and...
    Archive
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Dec 24 09:00:26 GMT 2023
    - 42.4K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/HttpUrl.kt

        }
    
      /**
       * The number of segments in this URL's path. This is also the number of slashes in this URL's
       * path, like 3 in `http://host/a/b/c`. This is always at least 1.
       *
       * | URL                  | `pathSize()` |
       * | :------------------- | :----------- |
       * | `http://host/`       | `1`          |
       * | `http://host/a/b/c`  | `3`          |
    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)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

            return true
          }
        }
    
        // If we have a routes left, use 'em.
        if (routeSelection?.hasNext() == true) return true
    
        // If we haven't initialized the route selector yet, assume it'll have at least one route.
        val localRouteSelector = routeSelector ?: return true
    
        // If we do have a route selector, use its routes.
        return localRouteSelector.hasNext()
      }
    
      /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/MultipartBody.kt

            apply {
              parts += part
            }
    
          /** Assemble the specified parts into a request body. */
          fun build(): MultipartBody {
            check(parts.isNotEmpty()) { "Multipart body must have at least one part." }
            return MultipartBody(boundary, type, parts.toImmutableList())
          }
        }
    
      companion object {
        /**
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        cache.close()
        createNewCacheWithSize(10)
        set("a", "a", "a")
        set("b", "b", "b")
        set("c", "c", "c")
        set("d", "d", "d")
        set("e", "e", "e")
        cache["b"]!!.close() // 'B' is now least recently used.
    
        // Causing the size to grow to 12 should evict 'A'.
        set("f", "f", "f")
        // Causing the size to grow to 12 should evict 'C'.
        set("g", "g", "g")
        cache.flush()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 14:55:09 GMT 2024
    - 75.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

            addressState.concurrentCallCapacity += connection.allocationLimit
          }
        }
    
        // Find the longest-idle connections in 2 categories:
        //
        //  1. OLD: Connections that have been idle for at least keepAliveDurationNs. We close these if
        //     we find them, regardless of what the address policies need.
        //
        //  2. EVICTABLE: Connections not required by any address policy. This matches connections that
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 16.2K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

            if (closed) return
            outFinished = errorCode == null
          }
          if (!sink.finished) {
            // We have 0 or more frames of data, and 0 or more frames of trailers. We need to send at
            // least one frame with the END_STREAM flag set. That must be the last frame, and the
            // trailers must be sent after all of the data.
            val hasData = sendBuffer.size > 0L
            val hasTrailers = trailers != null
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  10. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

        if (size > maxSize || journalRebuildRequired()) {
          cleanupQueue.schedule(cleanupTask)
        }
      }
    
      /**
       * We only rebuild the journal when it will halve the size of the journal and eliminate at least
       * 2000 ops.
       */
      private fun journalRebuildRequired(): Boolean {
        val redundantOpCompactThreshold = 2000
        return redundantOpCount >= redundantOpCompactThreshold &&
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 34.7K bytes
    - Viewed (0)
Back to top