Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 119 for cancel (0.17 sec)

  1. docs/distributed/DECOMMISSION.md

    `mc admin decommission cancel` without an argument, lists out any on-going decommission in progress.
    
    ```
    λ mc admin decommission cancel alias/
    ┌─────┬─────────────────────────────────┬──────────────────────────────────┬──────────┐
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 11 14:59:49 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  2. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt

            .build(),
        )
        listener.enqueueCancel() // Will cancel in onOpen().
        val request =
          Request.Builder()
            .url(server.url("/"))
            .build()
        val response = client.newCall(request).execute()
        processResponse(response, listener)
        listener.assertOpen()
        listener.assertFailure("canceled")
      }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  3. okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt

    @ExperimentalCoroutinesApi // resume with a resource cleanup.
    suspend fun Call.executeAsync(): Response =
      suspendCancellableCoroutine { continuation ->
        continuation.invokeOnCancellation {
          this.cancel()
        }
        this.enqueue(
          object : Callback {
            override fun onFailure(
              call: Call,
              e: IOException,
            ) {
              continuation.resumeWithException(e)
            }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Thu Apr 18 01:24:38 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/FailingCall.kt

      override fun request(): Request = error("unexpected")
    
      override fun execute(): Response = error("unexpected")
    
      override fun enqueue(responseCallback: Callback): Unit = error("unexpected")
    
      override fun cancel(): Unit = error("unexpected")
    
      override fun isExecuted(): Boolean = error("unexpected")
    
      override fun isCanceled(): Boolean = error("unexpected")
    
      override fun timeout(): Timeout = error("unexpected")
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 01 14:21:25 GMT 2024
    - 1.1K bytes
    - Viewed (0)
  5. 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)
      }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 9.2K bytes
    - Viewed (2)
  6. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

       */
      fun cancel()
    
      fun interface Factory {
        /**
         * Creates a new web socket and immediately returns it. Creating a web socket initiates an
         * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be
         * notified. The caller must either close or cancel the returned web socket when it is no longer
         * in use.
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

      @Throws(IOException::class)
      internal fun cancelStreamIfNecessary() {
        lock.assertNotHeld()
    
        val open: Boolean
        val cancel: Boolean
        this.withLock {
          cancel = !source.finished && source.closed && (sink.finished || sink.closed)
          open = isOpen
        }
        if (cancel) {
          // RST this stream to prevent additional data from being sent. This is safe because the input
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  8. okhttp/src/main/kotlin/okhttp3/internal/http2/PushObserver.kt

        streamId: Int,
        source: BufferedSource,
        byteCount: Int,
        last: Boolean,
      ): Boolean
    
      /** Indicates the reason why this stream was canceled. */
      fun onReset(
        streamId: Int,
        errorCode: ErrorCode,
      )
    
      companion object {
        @JvmField val CANCEL: PushObserver = PushObserverCancel()
    
        private class PushObserverCancel : PushObserver {
          override fun onRequest(
            streamId: Int,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.6K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

        call: Call,
        ioe: IOException,
      ) {
        logWithTime("callFailed: $ioe")
    
        delegate.callFailed(call, ioe)
      }
    
      override fun canceled(call: Call) {
        logWithTime("canceled")
    
        delegate.canceled(call)
      }
    
      override fun satisfactionFailure(
        call: Call,
        response: Response,
      ) {
        logWithTime("satisfactionFailure")
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 6K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/internal/duplex/MockStreamHandler.kt

        apply {
          actions += { stream ->
            if (!stream.requestBody.exhausted()) throw AssertionError("expected exhausted")
          }
        }
    
      fun cancelStream() =
        apply {
          actions += { stream -> stream.cancel() }
        }
    
      fun requestIOException() =
        apply {
          actions += { stream ->
            try {
              stream.requestBody.exhausted()
              throw AssertionError("expected IOException")
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 3.2K bytes
    - Viewed (0)
Back to top