Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 57 for acquire (0.22 sec)

  1. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt

     */
    internal fun sections(mappings: List<Mapping>): Map<Int, List<MappedRange>> {
      val result = mutableMapOf<Int, MutableList<MappedRange>>()
    
      for (mapping in mappings) {
        require(!mapping.spansSections)
    
        val section = mapping.section
        val rangeStart = mapping.rangeStart
    
        val sectionList = result.getOrPut(section) { mutableListOf() }
    
        sectionList +=
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

            if (stream.isOpen) {
              streams[streamId] = stream
            }
          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
            writer.pushPromise(associatedStreamId, streamId, requestHeaders)
          }
        }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/-ResponseCommon.kt

      }
    
    private fun checkSupportResponse(
      name: String,
      response: Response?,
    ) {
      response?.apply {
        require(networkResponse == null) { "$name.networkResponse != null" }
        require(cacheResponse == null) { "$name.cacheResponse != null" }
        require(priorResponse == null) { "$name.priorResponse != null" }
      }
    }
    
    fun Response.Builder.commonPriorResponse(priorResponse: Response?) =
      apply {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 15 13:24:48 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  4. okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsRecordCodec.kt

          writeShort(0) // additional
    
          val nameBuf = Buffer()
          val labels = host.split('.').dropLastWhile { it.isEmpty() }
          for (label in labels) {
            val utf8ByteCount = label.utf8Size()
            require(utf8ByteCount == label.length.toLong()) { "non-ascii hostname: $host" }
            nameBuf.writeByte(utf8ByteCount.toInt())
            nameBuf.writeUtf8(label)
          }
          nameBuf.writeByte(0) // end
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  5. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

          require(Protocol.H2_PRIOR_KNOWLEDGE !in protocolList || protocolList.size == 1) {
            "protocols containing h2_prior_knowledge cannot use other protocols: $protocolList"
          }
          require(Protocol.HTTP_1_1 in protocolList || Protocol.H2_PRIOR_KNOWLEDGE in protocolList) {
            "protocols doesn't contain http/1.1: $protocolList"
          }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Mar 31 17:16:15 GMT 2024
    - 37.4K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/-MediaTypeCommon.kt

      val parameterNamesAndValues = mutableListOf<String>()
      var s = typeSubtype.range.last + 1
      while (s < length) {
        val parameter = PARAMETER.matchAtPolyfill(this, s)
        require(parameter != null) {
          "Parameter is not formatted correctly: \"${substring(s)}\" for: \"$this\""
        }
    
        val name = parameter.groups[1]?.value
        if (name == null) {
          s = parameter.range.last + 1
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/osgi/OsgiTest.kt

        repositoryPlugin.deployDirectory(testResourceDir / "deployments")
        repositoryPlugin.deployClassPath()
      }
    
      private fun createBndRun(workspace: Workspace): Bndrun {
        // Creating the run require string. It will always use the latest version of each bundle
        // available in the repository.
        val runRequireString =
          REQUIRED_BUNDLES.joinToString(separator = ",") {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        if (flushHeaders) {
          connection.flush()
        }
      }
    
      fun enqueueTrailers(trailers: Headers) {
        this.withLock {
          check(!sink.finished) { "already finished" }
          require(trailers.size != 0) { "trailers.size() == 0" }
          this.sink.trailers = trailers
        }
      }
    
      fun readTimeout(): Timeout = readTimeout
    
      fun writeTimeout(): Timeout = writeTimeout
    
    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)
  9. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

                journalWriter?.closeQuietly()
                journalWriter = blackholeSink().buffer()
              }
    
              return -1L
            }
          }
        }
    
      init {
        require(maxSize > 0L) { "maxSize <= 0" }
        require(valueCount > 0) { "valueCount <= 0" }
    
        this.journalFile = directory / JOURNAL_FILE
        this.journalFileTmp = directory / JOURNAL_FILE_TEMP
    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)
  10. okhttp/src/test/java/okhttp3/internal/idn/IdnaMappingTableTest.kt

        assertThat(IDNA_MAPPING_TABLE.mappings).isEqualTo(compactTable.mappings)
      }
    
      private fun String.map(): String {
        val buffer = Buffer()
        for (codePoint in codePoints()) {
          require(table.map(codePoint, buffer))
        }
        return buffer.readUtf8()
      }
    
      private fun String.mapExpectingErrors(): String {
        val buffer = Buffer()
        var errorCount = 0
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8.9K bytes
    - Viewed (0)
Back to top