Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 277 for Exchange (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. compat/maven-artifact/src/main/java/org/apache/maven/artifact/repository/Authentication.java

            this.username = userName;
        }
    
        /**
         * Get the passphrase of the private key file. The passphrase is used only when host/protocol supports
         * authentication via exchange of private/public keys and private key was used for authentication.
         *
         * @return passphrase of the private key file
         */
        public String getPassphrase() {
            return passphrase;
        }
    
        /**
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  9. samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java

          listener.sessionGranted(session);
        } catch (IOException e) {
          return new MockResponse()
              .setResponseCode(400)
              .setBody("code exchange failed: " + e.getMessage());
        }
    
        synchronized (this) {
          listeners.remove(state);
        }
    
        // Success!
        return new MockResponse()
            .setResponseCode(302)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Aug 12 07:26:27 GMT 2021
    - 3.8K bytes
    - Click Count (1)
  10. docs/contribute/concurrency.md

     * **Exchange** carries a single HTTP request/response pair.
    
     * **ExchangeFinder** chooses which connection carries each exchange. Where possible it will use the same connection for all exchanges in a single call. It prefers reusing pooled connections over establishing new connections.      
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 16:35:36 GMT 2022
    - 7K bytes
    - Click Count (0)
Back to Top