- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for cdone (2.23 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
sourcePos += bytesRead // Append the upstream bytes to the file. fileOperator!!.write( FILE_HEADER_SIZE + upstreamPos, upstreamBuffer.clone(), upstreamBytesRead, ) synchronized(this@Relay) { // Append new upstream bytes into the buffer. Trim it to its max size. buffer.write(upstreamBuffer, upstreamBytesRead)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
deploy_website.sh
# https://squidfunk.github.io/mkdocs-material/ # It requires python3 to run. set -ex REPO="******@****.***:square/okhttp.git" DIR=temp-clone # Delete any existing temporary website clone rm -rf $DIR # Clone the current repo into temp folder git clone $REPO $DIR # Replace `git clone` with these lines to hack on the website locally # cp -a . "../okhttp-website" # mv "../okhttp-website" "$DIR"
Shell Script - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Nov 20 15:26:12 GMT 2023 - 1.2K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
lock.assertHeld() // If this connection is not accepting new exchanges, we're done. if (calls.size >= allocationLimit || noNewExchanges) return false // If the non-host fields of the address don't overlap, we're done. if (!this.route.address.equalsNonHost(address)) return false // If the host exactly matches, we're done: this connection can carry the address.
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) -
docs/changelogs/changelog_4x.md
is a view of what created it, we use _as_. * Fix: Permit response codes of zero for compatibility with OkHttp 3.x. * Fix: Change the return type of `MockWebServer.takeRequest()` to be nullable. * Fix: Make `Call.clone()` public to Kotlin callers. ## Version 4.0.0-RC1 _2019-06-03_ * First stable preview of OkHttp 4. ## Version 3.x [Change log](https://square.github.io/okhttp/changelog_3x/)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
port = serverSocket!!.localPort executor.execute { try { readAndWriteFrames() } catch (e: IOException) { ******@****.***uietly() logger.info("${this@MockHttp2Peer} done: ${e.message}") } } } private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun timeout(): Timeout = timeout @SuppressWarnings("CloneDoesntCallSuperClone") // We are a final type & this saves clearing state. override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an
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) -
okhttp/src/main/kotlin/okhttp3/internal/-HostnamesCommon.kt
// We've successfully read a group. Assign its value to our byte array. address[b++] = (value.ushr(8) and 0xff).toByte() address[b++] = (value and 0xff).toByte() } // All done. If compression happened, we need to move bytes to the right place in the // address. Here's a sample: // // input: "1111:2222:3333::7777:8888"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt
override fun isExecuted(): Boolean = error("unexpected") override fun isCanceled(): Boolean = error("unexpected") override fun timeout(): Timeout = error("unexpected") override fun clone(): Call = error("unexpected")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 1.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Cache.kt
private val body: Sink var done = false init { this.body = object : ForwardingSink(cacheOut) { @Throws(IOException::class) override fun close() { synchronized(this@Cache) { if (done) return done = true writeSuccessCount++ } super.close()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0)