- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for butter (0.24 sec)
-
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
import okio.BufferedSink import okio.ByteString import okio.ByteString.Companion.encodeUtf8 import okio.FileSystem import okio.Path import okio.Path.Companion.toPath import okio.buffer import okio.gzip /** * Downloads the public suffix list from https://publicsuffix.org/list/public_suffix_list.dat and * transforms the file into an efficient format used by OkHttp. * *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
// This check is imperfect: it doesn't tell us whether a handshake will succeed, just // that it will almost certainly fail because the proxy has sent unexpected data. if (source?.buffer?.exhausted() == false || sink?.buffer?.exhausted() == false) { throw IOException("TLS tunnel buffered too many bytes!") } user.secureConnectStart() // Create the wrapper over the connected socket.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
import okhttp3.internal.writeMedium import okio.Buffer import okio.BufferedSink /** Writes HTTP/2 transport frames. */ @Suppress("NAME_SHADOWING") class Http2Writer( private val sink: BufferedSink, private val client: Boolean, ) : Closeable { internal val lock: ReentrantLock = ReentrantLock() private val hpackBuffer: Buffer = Buffer() private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
byteCount: Int, inFinished: Boolean, ) { val buffer = Buffer() source.require(byteCount.toLong()) // Eagerly read the frame before firing client thread. source.read(buffer, byteCount.toLong()) pushQueue.execute("$connectionName[$streamId] onData") { ignoreIoExceptions { val cancel = pushObserver.onData(streamId, buffer, byteCount, inFinished)
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) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
// Do blocking calls to plan a route for a new connection. val connect = planConnect() // Now that we have a set of IP addresses, make another attempt at getting a connection from // the pool. We have a better chance of matching thanks to connection coalescing. val pooled2 = planReusePooledConnection(connect, connect.routes) if (pooled2 != null) return pooled2 return connect } /**
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) -
CHANGELOG.md
include this file on GraalVM. ## Version 5.0.0-alpha.4 _2022-02-01_ **This release introduces fast fallback to better support mixed IPv4+IPv6 networks.** Fast fallback is what we're calling our implementation of Happy Eyeballs, [RFC 8305][rfc_8305]. With this
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
/** Maximum number of bytes to buffer before reporting a flow control error. */ private val maxByteCount: Long, /** * True if either side has cleanly shut down this stream. We will receive no more bytes beyond * those already in the buffer. */ internal var finished: Boolean, ) : Source { /** Buffer to receive data from the network into. Only accessed by the reader thread. */
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) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
import okhttp3.HttpUrl.Companion.toHttpUrl import okhttp3.OkHttpClientTestRule import okhttp3.Protocol import okhttp3.Request import okhttp3.Response import okhttp3.ResponseBody import okio.Buffer import okio.ForwardingSource import okio.buffer import org.junit.jupiter.api.BeforeEach import org.junit.jupiter.api.Test import org.junit.jupiter.api.extension.RegisterExtension import org.junit.jupiter.api.fail class ExecuteAsyncTest {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 5.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(stream.takeHeaders()).isEqualTo(headersOf("a", "android")) val source = stream.getSource() val buffer = Buffer() buffer.writeAll(source) assertThat(source.read(buffer, 1)).isEqualTo(-1) assertThat(buffer.size).isEqualTo(150) val synStream = peer.takeFrame() assertThat(synStream.type).isEqualTo(Http2.TYPE_HEADERS) for (i in 0..2) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0)