- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 345 for Exchange (0.12 seconds)
-
impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/SimplexTransferListener.java
private void put(TransferEvent event, boolean last) { try { Exchange exchange; if (blockOnLastEvent && last) { exchange = new BlockingExchange(event); } else { exchange = new Exchange(event); } eventQueue.put(exchange); exchange.waitForProcessed(); } catch (InterruptedException e) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Feb 06 11:28:05 GMT 2025 - 8.7K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
private void put(TransferEvent event, boolean last) { try { Exchange exchange; if (blockOnLastEvent && last) { exchange = new BlockingExchange(event); } else { exchange = new Exchange(event); } eventQueue.put(exchange); exchange.waitForProcessed(); } catch (InterruptedException e) {Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 8.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt
@Throws(IOException::class) override fun intercept(chain: Interceptor.Chain): Response { val realChain = chain as RealInterceptorChain val exchange = realChain.call.initExchange(realChain) val connectedChain = realChain.copy(exchange = exchange) return connectedChain.proceed(realChain.request) }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 1.5K bytes - Click Count (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
* connection index, they also shared a socket connection. */ public val connectionIndex: Int, /** * The index of this exchange on its HTTP connection. A request is uniquely identified by the * (connection index, exchange index) pair. */ public val exchangeIndex: Int, /** * The TLS handshake of the connection that carried this request, or null if the request was
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Jun 21 20:36:35 GMT 2025 - 3.2K bytes - Click Count (1) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt
import okhttp3.Address import okhttp3.HttpUrl /** * Policy on choosing which connection to use for an exchange and any retries that follow. This uses * the following strategies: * * 1. If the current call already has a connection that can satisfy the request it is used. Using * the same connection for an initial exchange and its follow-ups may improve locality. *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue May 27 14:58:02 GMT 2025 - 4.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/ExchangeCodec.kt
val carrier: Carrier /** Returns true if the response body and (possibly empty) trailers have been received. */ val isResponseComplete: Boolean /** The socket that carries this exchange. */ val socket: Socket /** Returns an output stream where the request body can be streamed. */ @Throws(IOException::class) fun createRequestBody( request: Request, contentLength: Long, ): Sink
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jul 29 21:11:09 GMT 2025 - 3.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 1.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
if ("100-continue".equals(request.header("Expect"), ignoreCase = true)) { exchange.flushRequest() responseBuilder = exchange.readResponseHeaders(expectContinue = true) exchange.responseHeadersStart() invokeStartEvent = false } if (responseBuilder == null) { if (requestBody.isDuplex()) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Oct 30 13:46:58 GMT 2025 - 7.6K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Callback.kt
package okhttp3 import okio.IOException interface Callback { /** * Called when the request could not be executed due to cancellation, a connectivity problem or * timeout. Because networks can fail during an exchange, it is possible that the remote server * accepted the request before the failure. */ fun onFailure( call: Call, e: IOException, ) /**Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 1.6K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/sso/SsoAuthenticator.java
* OAuth, SPNEGO, or other authentication mechanisms. Each authenticator is responsible * for obtaining login credentials, resolving user information, and managing SSO * lifecycle operations like logout and metadata exchange. */ public interface SsoAuthenticator { /** * Gets the login credential for SSO authentication. * @return The login credential. */ LoginCredential getLoginCredential(); /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Jul 17 08:28:31 GMT 2025 - 2.2K bytes - Click Count (1)