- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,192 for call$ (0.06 sec)
-
mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt
) .dns(dns) .build() server.enqueue(MockResponse()) val url = server.url("/").newBuilder().host("localhost.localdomain").build() val call = client.newCall(Request(url = url)) val response = call.execute() assertThat(response.isSuccessful).isTrue() val recordedRequest = server.takeRequest() assertThat(recordedRequest.handshakeServerNames).containsExactly(url.host) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.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,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.7K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
call: Call, connection: Connection, ) = logEvent(ConnectionReleased(System.nanoTime(), call, connection)) override fun callStart(call: Call) = logEvent(CallStart(System.nanoTime(), call)) override fun requestHeadersStart(call: Call) = logEvent(RequestHeadersStart(System.nanoTime(), call)) override fun requestHeadersEnd( call: Call, request: Request,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/386.s
// LTYPEC spec3 { outcode(int($1), &$2); } CALL AX JCS 2(PC) JMP *AX // JMP AX CALL *foo(SB) JCS 2(PC) JMP $4 JCS 2(PC) JMP label // JMP 16 CALL foo(SB) // CALL (AX*4) // TODO: This line is silently dropped on the floor! CALL foo+4(SB)(AX*4) CALL *4(SP) // CALL 4(SP) CALL *(AX) // CALL (AX) CALL *(SP) // CALL (SP) // CALL *(AX*4) // TODO: This line is silently dropped on the floor!
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Apr 09 18:57:21 UTC 2019 - 2K bytes - Viewed (0) -
guava/src/com/google/common/collect/PeekingIterator.java
* * <p>The objects returned by consecutive calls to {@link #peek()} then {@link #next()} are * guaranteed to be equal to each other. */ @CanIgnoreReturnValue @Override @ParametricNullness E next(); /** * {@inheritDoc} * * <p>Implementations may or may not support removal when a call to {@link #peek()} has occurred * since the most recent call to {@link #next()}. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 24 17:47:51 UTC 2022 - 2.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
@ExperimentalOkHttpApi abstract class ConnectionListener { /** * Invoked as soon as a call causes a connection to be started. */ open fun connectStart( route: Route, call: Call, ) {} /** * Invoked when a connection fails to be established. */ open fun connectFailed( route: Route, call: Call, failure: IOException, ) {} /**
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 2.2K bytes - Viewed (0) -
fastapi/dependencies/utils.py
elif is_gen_callable(call) or is_async_gen_callable(call): solved = await solve_generator( call=call, stack=async_exit_stack, sub_values=solved_result.values ) elif is_coroutine_callable(call): solved = await call(**solved_result.values) else: solved = await run_in_threadpool(call, **solved_result.values)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 21:46:26 UTC 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
if (e != null) { eventListener.requestFailed(call, e) } else { eventListener.requestBodyEnd(call, bytesRead) } } if (responseDone) { if (e != null) { eventListener.responseFailed(call, e) } else { eventListener.responseBodyEnd(call, bytesRead) } } return call.messageDone(this, requestDone, responseDone, e) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
.build() val latch = CountDownLatch(1) val exceptionRef = AtomicReference<Throwable>() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) call.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { exceptionRef.set(e) latch.countDown() }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.5K bytes - Viewed (0) -
okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt
runTest { val call = ClosableCall() supervisorScope { assertFailsWith<CancellationException> { coroutineScope { call.afterCallbackOnResponse = { coroutineContext.job.cancel() } call.executeAsync() } } } assertThat(call.canceled).isTrue()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 18 01:24:38 UTC 2024 - 5.4K bytes - Viewed (0)