Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 205 for cancelled (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

       * input future and that of the future returned by the chain function. That is, if the returned
       * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
       * other two is cancelled, the returned {@code Future} will receive a callback in which it will
       * attempt to cancel itself.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/MoreExecutors.java

            this.scheduledDelegate = scheduledDelegate;
          }
    
          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
              // Unless it is cancelled, the delegate may continue being scheduled
              scheduledDelegate.cancel(mayInterruptIfRunning);
    
              /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  3. src/test/java/jcifs/smb/SmbWatchHandleImplTest.java

            assertTrue(ex.getMessage().contains("Did not receive response"));
        }
    
        // If the request is cancelled (NTSTATUS 0xC0000120), return null
        @Test
        @DisplayName("watch() returns null when request cancelled (NTSTATUS 0xC0000120)")
        void watch_sendCancelled_returnsNull() throws Exception {
            when(handle.isValid()).thenReturn(true);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbWatchHandleImpl.java

                } catch (final SmbException e) {
                    if (e.getNtStatus() == 0xC0000120) {
                        // cancelled
                        log.debug("Request was cancelled", e);
                        return null;
                    }
                    throw e;
                }
                if (log.isTraceEnabled()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
         * and then. This means that we're silently swallowing an exception -- maybe even an Error. But
         * this is no worse than what FutureTask does in that situation. Additionally, because the
         * Future was cancelled, its listeners have been run, so its consumers will not hang.
         *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        }
    
        manualExecutorTask[0].run();
    
        for (Future<?> result : results) {
          if (!result.isCancelled()) {
            result.get(10, SECONDS);
          }
          // TODO(cpovirk): Verify that the cancelled futures are exactly ones that we expect.
        }
    
        assertThat(logHandler.getStoredLogRecords()).isEmpty();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  7. architecture/standards/0009-use-american-english.md

    * `color` (not `colour`)
    * `initialize` (not `initialise`)
    * `behavior` (not `behaviour`)
    * `analyze` (not `analyse`)
    * `organization` (not `organisation`)
    * `center` (not `centre`)
    * `canceled` (not `cancelled`)
    * `labeled` (not `labelled`)
    
    ### Rationale for American English
    
    American English was chosen for the following reasons:
    
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Tue Nov 25 07:01:54 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  8. chainable_api.go

    	for _, scope := range scopes {
    		db = scope(db)
    	}
    	return db
    }
    
    // Preload preload associations with given conditions
    //
    //	// get all users, and preload all non-cancelled orders
    //	db.Preload("Orders", "state NOT IN (?)", "cancelled").Find(&users)
    func (db *DB) Preload(query string, args ...interface{}) (tx *DB) {
    	tx = db.getInstance()
    	if tx.Statement.Preloads == nil {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Sep 19 01:49:06 UTC 2025
    - 14.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        }
    
        @Override
        public boolean isCancelled() {
          return delegate.isCancelled();
        }
      }
    
      /**
       * A {@link Scheduler} that provides a convenient way for the {@link AbstractScheduledService} to
       * use a dynamically changing schedule. After every execution of the task, assuming it hasn't been
       * cancelled, the {@link #getNextSchedule} method will be called.
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

     *
     * <p>Future that delegates to another but will finish early (via a {@link TimeoutException} wrapped
     * in an {@link ExecutionException}) if the specified duration expires. The delegate future is
     * interrupted and cancelled if it times out.
     */
    @J2ktIncompatible
    @GwtIncompatible
    final class TimeoutFuture<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> {
      static <V extends @Nullable Object> ListenableFuture<V> create(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top