- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for methods (0.26 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
* in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. * * This method is safe to be called concurrently, but provides limited guarantees. If a transport * layer connection has been established (such as a HTTP/2 stream) that is terminated. Otherwise
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/http2/Http2Connection.kt
* * Multiple calls to this method may be made concurrently. */ @Throws(IOException::class) abstract fun onStream(stream: Http2Stream) /** * Notification that the connection's peer's settings may have changed to [settings]. * Implementations should take appropriate action to handle the updated settings. *
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/http2/Http2Writer.kt
* `streamId`. * * @param streamId client-initiated stream ID. Must be an odd number. * @param promisedStreamId server-initiated stream ID. Must be an even number. * @param requestHeaders minimally includes `:method`, `:scheme`, `:authority`, and `:path`. */ @Throws(IOException::class) fun pushPromise( streamId: Int, promisedStreamId: Int, requestHeaders: List<Header>, ) { this.withLock {
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/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
connection.readerRunnable.applyAndAckSettings(true, settings) assertThat(connection.peerSettings[Settings.MAX_CONCURRENT_STREAMS]).isEqualTo(amount) taskFaker.runTasks() } /** Use a helper method so there's no hidden reference remaining on the stack. */ private fun allocateAndLeakAllocation( pool: ConnectionPool, connection: RealConnection, ) { val client = OkHttpClient.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
*/ @Throws(IOException::class) private fun createTunnelRequest(route: Route): Request { val proxyConnectRequest = Request.Builder() .url(route.address.url) .method("CONNECT", null) .header("Host", route.address.url.toHostHeader(includeDefaultPort = true)) .header("Proxy-Connection", "Keep-Alive") // For HTTP/1.0 proxies like Squid. .header("User-Agent", USER_AGENT)
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) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
) { lock.assertNotHeld() val open: Boolean this.withLock { if (!hasResponseHeaders || headers[Header.RESPONSE_STATUS_UTF8] != null || headers[Header.TARGET_METHOD_UTF8] != null ) { hasResponseHeaders = true headersQueue += headers } else { this.source.trailers = headers } if (inFinished) {
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/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
* either it has exceeded the keep alive limit or the idle connections limit. * * Returns the duration in nanoseconds to sleep until the next scheduled call to this method. * Returns -1 if no further cleanups are required. */ fun closeConnections(now: Long): Long { // Compute the concurrent call capacity for each address. We won't close a connection if doing
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
peer.acceptFrame() // ACK peer.acceptFrame() // SYN_STREAM peer.sendFrame().headers(false, 3, headerEntries("a", "android")) val expectedRequestHeaders = listOf( Header(Header.TARGET_METHOD, "GET"), Header(Header.TARGET_SCHEME, "https"), Header(Header.TARGET_AUTHORITY, "squareup.com"), Header(Header.TARGET_PATH, "/cached"), )
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) -
okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10001 finished run in 0 µs: task two", "FINE: Q10002 starting : task three", "FINE: Q10002 finished run in 0 µs: task three", ) } /** Test the introspection method [TaskQueue.scheduledTasks]. */ @Test fun scheduledTasks() { redQueue.execute("task one", 100.µs) { // Do nothing. } redQueue.execute("task two", 200.µs) { // Do nothing. }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 23K bytes - Viewed (0)