- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,963 for call (0.17 sec)
-
okhttp/src/main/kotlin/okhttp3/Call.kt
*/ package okhttp3 import okio.IOException import okio.Timeout /** * A call is a request that has been prepared for execution. A call can be canceled. As this object * represents a single request/response pair (stream), it cannot be executed twice. */ interface Call : Cloneable { /** Returns the original request that initiated this call. */ fun request(): Request /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
var socket: SSLSocket? = null var closed = false override fun connectionAcquired( call: Call, connection: Connection, ) { socket = connection.socket() as SSLSocket } override fun requestHeadersStart(call: Call) { if (closed) { throw IOException("fake socket failure") } } }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// The first call times out. val call1 = client.newCall(Request(server.url("/"))) assertFailsWith<SocketTimeoutException> { call1.execute().use { response -> response.body.string() } } // The second call succeeds. val call2 = client.newCall(Request(server.url("/"))) call2.execute().use { response -> assertThat(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
override fun connectionAcquired( call: Call, connection: Connection, ) { // We have the connection and it's in the pool. Let request2 proceed to make a connection. latch2.countDown() } } val request2Listener: EventListener = object : EventListener() { override fun connectStart( call: Call, inetSocketAddress: InetSocketAddress,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
public void testReturning() throws Exception { assertNull(Callables.returning(null).call()); Object value = new Object(); Callable<Object> callable = Callables.returning(value); assertSame(value, callable.call()); // Expect the same value on subsequent calls assertSame(value, callable.call()); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable() throws Exception {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0) -
docs/features/calls.md
## [Calls](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-call/)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
.write(ByteArray(responseBodySize)), ) .throttleBody(64 * 1024, 125, MILLISECONDS) // 500 Kbps .build(), ) val call = client.newCall(Request(server.url("/"))) val response = call.execute() cancelLater(call, 500) val responseBody = response.body.byteStream() val buffer = ByteArray(1024) assertFailsWith<IOException> { while (responseBody.read(buffer) != -1) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt
) : CallEvent() data class SecureConnectEnd( override val timestampNs: Long, override val call: Call, val handshake: Handshake?, ) : CallEvent() { override fun closes(event: CallEvent): Boolean = event is SecureConnectStart && call == event.call } data class ConnectionAcquired( override val timestampNs: Long, override val call: Call, val connection: Connection,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.7K bytes - Viewed (0) -
cmd/peer-rest-client.go
all = make([]*peerRESTClient, len(hosts)) for i, host := range hosts { if host == nil { continue } all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host)) remote = append(remote, all[i]) } if len(all) != len(remote)+1 { peersLogIf(context.Background(), fmt.Errorf("Expected number of all hosts (%v) to be remote +1 (%v)", len(all), len(remote)), logger.WarningKind) }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10CallResolver.kt
val call = element.getResolvedCall(context) ?: return null return call.toPropertyRead(context)?.let { createCallInfo(context, element, it, listOf(call)) } } /** * Handles call expressions like `Foo<Bar>` or `test.Foo<Bar>` in calls like `Foo<Bar>::foo` and `test.Foo<Bar>::foo`. *
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Mar 14 06:10:31 GMT 2024 - 36.4K bytes - Viewed (0)