Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 433 for exchange (0.08 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt

      fun noNewExchangesOnConnection() {
        codec.carrier.noNewExchanges()
      }
    
      fun cancel() {
        codec.cancel()
      }
    
      /**
       * Revoke this exchange's access to streams. This is necessary when a follow-up request is
       * required but the preceding exchange hasn't completed yet.
       */
      fun detachWithViolence() {
        codec.cancel()
        call.messageDone(this, requestDone = true, responseDone = true, e = null)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. 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) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

      private val index: Int,
      internal val exchange: Exchange?,
      internal val request: Request,
      internal val connectTimeoutMillis: Int,
      internal val readTimeoutMillis: Int,
      internal val writeTimeoutMillis: Int,
    ) : Interceptor.Chain {
      private var calls: Int = 0
    
      internal fun copy(
        index: Int = this.index,
        exchange: Exchange? = this.exchange,
        request: Request = this.request,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/Response.kt

          apply {
            this.receivedResponseAtMillis = receivedResponseAtMillis
          }
    
        internal fun initExchange(exchange: Exchange) {
          this.exchange = exchange
          this.trailersFn = { exchange.trailers() }
        }
    
        open fun build(): Response {
          check(code >= 0) { "code < 0: $code" }
          return Response(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 06 09:38:30 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt

          if (shouldIgnoreAndWaitForRealResponse(code, exchange)) {
            responseBuilder = exchange.readResponseHeaders(expectContinue = false)!!
            if (invokeStartEvent) {
              exchange.responseHeadersStart()
            }
            response =
              responseBuilder
                .request(request)
                .handshake(exchange.connection.handshake())
                .sentRequestAtMillis(sentRequestMillis)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

        exchange: Exchange,
        requestDone: Boolean,
        responseDone: Boolean,
        e: E,
      ): E {
        if (exchange != this.exchange) return e // This exchange was detached violently!
    
        var bothStreamsDone = false
        var callDone = false
        this.withLock {
          if (requestDone && requestBodyOpen || responseDone && responseBodyOpen) {
            if (requestDone) requestBodyOpen = false
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt

    }
    
    internal var RealConnection.idleAtNsAccessor: Long
      get() = idleAtNs
      set(value) {
        idleAtNs = value
      }
    
    internal val Response.exchangeAccessor: Exchange?
      get() = this.exchange
    
    internal val Exchange.connectionAccessor: RealConnection
      get() = this.connection
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt

                .request(request)
                .priorResponse(priorResponse?.stripBody())
                .build()
    
            val exchange = call.interceptorScopedExchange
            val followUp = followUpRequest(response, exchange)
    
            if (followUp == null) {
              if (exchange != null && exchange.isDuplex) {
                call.timeoutEarlyExit()
              }
              closeActiveExchange = false
              return response
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. okhttp/src/main/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)
      }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

              response: Response,
            ) {
              val exchange = response.exchange
              val streams: Streams
              try {
                checkUpgradeSuccess(response, exchange)
                streams = exchange!!.newWebSocketStreams()
              } catch (e: IOException) {
                failWebSocket(e, response)
                response.closeQuietly()
                exchange?.webSocketUpgradeFailed()
                return
              }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top