Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 49 for cancellation (0.13 seconds)

  1. regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt

    import java.util.concurrent.ExecutionException
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.Executors
    import java.util.concurrent.TimeUnit
    import kotlin.coroutines.cancellation.CancellationException
    import okio.Buffer
    import org.junit.After
    import org.junit.Assert.assertEquals
    import org.junit.Assert.assertTrue
    import org.junit.Test
    import org.junit.runner.RunWith
    
    /**
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  2. cmd/erasure-metadata-utils_test.go

    		{
    			[]error{
    				errFileNotFound, errFileNotFound, errFileNotFound,
    				errFileNotFound, errFileNotFound, nil, nil, nil, nil, nil,
    			},
    			nil, nil,
    		},
    		// Checks if wrapped context cancellation errors are grouped as one.
    		{canceledErrs, nil, context.Canceled},
    	}
    	// Validates list of all the testcases for returning valid errors.
    	for i, testCase := range testCases {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks
     * automate the process, often adding features like monitoring, debugging, and cancellation.
     * Examples of frameworks include:
     *
     * <ul>
     *   <li><a href="https://dagger.dev/producers.html">Dagger Producers</a>
     * </ul>
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

       * Implementations must support such concurrent calls.
       *
       * Note that cancellation is best-effort and that a call may proceed normally after it has been
       * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may
       * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O
       * operation is required.
       *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  6. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks
     * automate the process, often adding features like monitoring, debugging, and cancellation.
     * Examples of frameworks include:
     *
     * <ul>
     *   <li><a href="https://dagger.dev/producers.html">Dagger Producers</a>
     * </ul>
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  7. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * FluentFuture.transform}), but you will often find it easier to use a framework. Frameworks
     * automate the process, often adding features like monitoring, debugging, and cancellation.
     * Examples of frameworks include:
     *
     * <ul>
     *   <li><a href="https://dagger.dev/producers.html">Dagger Producers</a>
     * </ul>
     *
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  9. cmd/erasure-metadata-utils.go

    	errorCounts := make(map[error]int)
    	for _, err := range errs {
    		if IsErrIgnored(err, ignoredErrs...) {
    			continue
    		}
    		// Errors due to context cancellation may be wrapped - group them by context.Canceled.
    		if errors.Is(err, context.Canceled) {
    			errorCounts[context.Canceled]++
    			continue
    		}
    		errorCounts[err]++
    	}
    
    	maxCnt := 0
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

           * cycle_suppress_list.txt.
           */
          private final AbstractService service;
    
          /**
           * This lock is used to ensure safe and correct cancellation, it ensures that a new task is
           * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to
           * ensure that it is assigned atomically with being scheduled.
           */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
Back to Top