Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 161 for isNone (0.13 sec)

  1. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

              protected void finalize() {
                future.set(null);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_Future_Cancel() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.4K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  if (!future.isDone()) {
                    errorMessage.set("Set call exited before future was complete.");
                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.setException(new IllegalArgumentException("failure"));
                  if (!future.isDone()) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

                  if (!future.isDone()) {
                    errorMessage.set("Set call exited before future was complete.");
                  }
                }
              });
          executor.execute(
              new Runnable() {
                @Override
                public void run() {
                  future.setException(new IllegalArgumentException("failure"));
                  if (!future.isDone()) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
        assertNotNull(e.getCause());
      }
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 05 22:27:35 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  8. pkg/auth/nodeidentifier/default.go

    		return "", false
    	}
    
    	userName := u.GetName()
    	if !strings.HasPrefix(userName, nodeUserNamePrefix) {
    		return "", false
    	}
    
    	isNode := false
    	for _, g := range u.GetGroups() {
    		if g == user.NodesGroup {
    			isNode = true
    			break
    		}
    	}
    	if !isNode {
    		return "", false
    	}
    
    	nodeName := strings.TrimPrefix(userName, nodeUserNamePrefix)
    	return nodeName, true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 15 09:32:31 UTC 2017
    - 1.9K bytes
    - Viewed (0)
  9. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

              }
            };
        ScheduledFuture<?> future =
            TestingExecutors.noOpScheduledExecutor().schedule(task, 10, TimeUnit.MILLISECONDS);
        Thread.sleep(20);
        assertFalse(taskDone);
        assertFalse(future.isDone());
      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  10. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

              }
            };
        ScheduledFuture<?> future =
            TestingExecutors.noOpScheduledExecutor().schedule(task, 10, TimeUnit.MILLISECONDS);
        Thread.sleep(20);
        assertFalse(taskDone);
        assertFalse(future.isDone());
      }
    
      public void testNoOpScheduledExecutorShutdown() {
        ListeningScheduledExecutorService executor = TestingExecutors.noOpScheduledExecutor();
        assertFalse(executor.isShutdown());
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.7K bytes
    - Viewed (0)
Back to top