Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 354 for canceled (0.08 sec)

  1. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

              ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = tcpConnectThrowable)
            }
            canceled -> {
              events += "plan $id TCP connect canceled"
              ConnectResult(this, nextPlan = connectTcpNextPlan, throwable = IOException("canceled"))
            }
            connectTcpNextPlan != null -> {
              events += "plan $id needs follow-up"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

       */
      override fun cancel() {
        if (canceled) return // Already canceled.
    
        canceled = true
        exchange?.cancel()
        for (plan in plansToCancel) {
          plan.cancel()
        }
    
        eventListener.canceled(this)
      }
    
      override fun isCanceled(): Boolean = canceled
    
      override fun execute(): Response {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  3. internal/grid/stream.go

    // Results returns the results from the remote server one by one.
    // If any error is returned by the callback, the stream will be canceled.
    // If the context is canceled, the stream will be canceled.
    func (s *Stream) Results(next func(b []byte) error) (err error) {
    	done := false
    	defer func() {
    		if s.cancel != nil {
    			s.cancel(err)
    		}
    
    		if !done {
    			// Drain channel.
    			for range s.responses {
    			}
    		}
    	}()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. okhttp-sse/src/main/kotlin/okhttp3/sse/internal/RealEventSource.kt

            }
          } catch (e: Exception) {
            val exception =
              when {
                canceled -> IOException("canceled", e)
                else -> e
              }
            listener.onFailure(this, exception, response)
            return
          }
          if (canceled) {
            listener.onFailure(this, IOException("canceled"), response)
          } else {
            listener.onClosed(this)
          }
        }
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/timer/TimeoutTask.java

            return permanent;
        }
    
        /**
         * キャンセルされているかどうかを返します。
         *
         * @return キャンセルされているか
         */
        public boolean isCanceled() {
            return status == CANCELED;
        }
    
        /**
         * キャンセルします。
         */
        public void cancel() {
            status = CANCELED;
        }
    
        /**
         * 止まっているかどうか返します。
         *
         * @return 止まっているかどうか
         */
        public boolean isStopped() {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

                    }
                  }.buffer()
              },
            )
            .build()
    
        var responseClosed = false
        var canceled = false
        var afterCallbackOnResponse: () -> Unit = {}
    
        override fun cancel() {
          canceled = true
        }
    
        override fun enqueue(responseCallback: Callback) {
          responseCallback.onResponse(this, response)
          afterCallbackOnResponse()
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/Call.kt

       */
      fun enqueue(responseCallback: Callback)
    
      /** Cancels the request, if possible. Requests that are already complete cannot be canceled. */
      fun cancel()
    
      /**
       * Returns true if this call has been either [executed][execute] or [enqueued][enqueue]. It is an
       * error to execute a call more than once.
       */
      fun isExecuted(): Boolean
    
      fun isCanceled(): Boolean
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 3.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2ExchangeCodec.kt

        stream = http2Connection.newStream(requestHeaders, hasRequestBody)
        // We may have been asked to cancel while creating the new stream and sending the request
        // headers, but there was still no stream to close.
        if (canceled) {
          stream!!.closeLater(ErrorCode.CANCEL)
          throw IOException("Canceled")
        }
        stream!!.readTimeout().timeout(chain.readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/DefaultEncryptInvoker.java

        }
    
        public static final int OK = 0; // OK
        public static final int ERROR = 1; // "generic" error
        public static final int BAD_OPERATION = 2; // bad user input or alike
        public static final int CANCELED = 3; // user canceled
    
        protected int doExecute(LocalContext context) throws Exception {
            try {
                if (!context.interactive) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        taskFaker.advanceUntil(500.ms)
        assertEvents(
          "take plan 2",
          "plan 0 cancel",
          "plan 1 cancel",
        )
    
        taskFaker.advanceUntil(510.ms)
        assertEvents(
          "plan 1 TCP connect canceled",
        )
    
        taskFaker.advanceUntil(520.ms)
        assertEvents(
          "plan 0 TCP connect canceled",
        )
      }
    
      @Test
      fun takeMultipleConnections() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top