Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for cancellation (0.53 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

       * necessarily indicate application-layer success: `response` may still indicate an unhappy HTTP
       * response code like 404 or 500.
       *
       * @throws IOException if 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.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/Task.kt

     * earliest one wins. This applies to both executions scheduled with [TaskRunner.Queue.schedule] and
     * those implied by the returned execution delay.
     *
     * Cancellation
     * ------------
     *
     * Tasks may be canceled while they are waiting to be executed, or while they are executing.
     *
     * Canceling a task that is waiting to execute prevents that upcoming execution. Canceling a task
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
      private ClassLoader oldClassLoader;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
      private ClassLoader oldClassLoader;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      /**
       * Tests that a canceled future throws a cancellation exception.
       *
       * <p>This method checks the cancel, isCancelled, and isDone methods.
       */
      public void testCanceledFutureThrowsCancellation() throws Exception {
    
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. okhttp-coroutines/README.md

      }
    }
    ```
    
    This is implemented using `suspendCancellableCoroutine`
    but uses the standard Dispatcher in OkHttp. This means
    that by default Kotlin's Dispatchers are not used.
    
    Cancellation if implemented sensibly in both directions.
    Cancelling a coroutine scope, will cancel the call.
    Cancelling a call, will throw a CancellationException
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Nov 09 15:47:27 UTC 2023
    - 609 bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      /**
       * Tests that a canceled future throws a cancellation exception.
       *
       * <p>This method checks the cancel, isCancelled, and isDone methods.
       */
      public void testCanceledFutureThrowsCancellation() throws Exception {
    
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  8. internal/stmt_store/stmt_store.go

    type Store interface {
    	// New creates a new Stmt object and caches it.
    	// Parameters:
    	//   ctx: The context for the request, which can carry deadlines, cancellation signals, etc.
    	//   key: The key representing the SQL query, used for caching and preparing the statement.
    	//   isTransaction: Indicates whether this operation is part of a transaction, which may affect the caching strategy.
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun Apr 27 06:05:16 UTC 2025
    - 6K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Callback.kt

     * limitations under the License.
     */
    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,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/CommonServerMessageBlockRequest.java

    /**
     * Interface for SMB request messages sent from client to server.
     * Extends the common SMB message block with request-specific functionality including
     * asynchronous handling, message chaining, cancellation, and timeout management.
     *
     * @author mbechler
     */
    public interface CommonServerMessageBlockRequest extends CommonServerMessageBlock, Request {
    
        /**
         * Checks if the request will be handled asynchronously.
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.4K bytes
    - Viewed (0)
Back to top