failureCase - Code Search

android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

    assertThat(getDone(immediateVoidFuture())).isEqualTo(null);
  }

  public void testFailed() {
    Exception failureCause = new Exception();
    ExecutionException expected =
        assertThrows(ExecutionException.class, () -> getDone(immediateFailedFuture(failureCause)));
    assertThat(expected).hasCauseThat().isEqualTo(failureCause);
  }

  public void testCancelled() throws ExecutionException {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Sep 23 01:35:55 GMT 2025

- 2.3K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java

    assertThat(getDone(immediateVoidFuture())).isEqualTo(null);
  }

  public void testFailed() {
    Exception failureCause = new Exception();
    ExecutionException expected =
        assertThrows(ExecutionException.class, () -> getDone(immediateFailedFuture(failureCause)));
    assertThat(expected).hasCauseThat().isEqualTo(failureCause);
  }

  public void testCancelled() throws ExecutionException {

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Tue Sep 23 01:35:55 GMT 2025

- 2.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

    assertThrows(IllegalStateException.class, service::failureCause);
    service.startAsync().awaitRunning();
    assertThrows(IllegalStateException.class, service::failureCause);
    IllegalStateException e =
        assertThrows(IllegalStateException.class, () -> service.stopAsync().awaitTerminated());
    assertEquals(EXCEPTION, service.failureCause());
    assertThat(e).hasCauseThat().isEqualTo(EXCEPTION);
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 28.7K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

    assertThrows(IllegalStateException.class, service::failureCause);
    service.startAsync().awaitRunning();
    assertThrows(IllegalStateException.class, service::failureCause);
    IllegalStateException e =
        assertThrows(IllegalStateException.class, () -> service.stopAsync().awaitTerminated());
    assertEquals(EXCEPTION, service.failureCause());
    assertThat(e).hasCauseThat().isEqualTo(EXCEPTION);
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 28.7K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

    executionThread.join();

    assertTrue(service.startUpCalled);
    assertEquals(Service.State.FAILED, service.state());
    assertThat(service.failureCause()).hasMessageThat().isEqualTo("kaboom!");
  }

  private class ThrowOnStartUpService extends AbstractExecutionThreadService {
    private boolean startUpCalled = false;

    @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 12.8K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/util/SmbCircuitBreaker.java

            // If failure rate is high but response time is normal, be more lenient
            if (failureRate > 0.5 && avgResponseTime < 5000) {
                newThreshold = Math.min(currentThreshold + 2, 15);
            }
            // If failure rate is moderate but response time is very high, be stricter
            else if (failureRate > 0.2 && avgResponseTime > 10000) {
                newThreshold = Math.max(currentThreshold - 1, 2);

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 30 05:58:03 GMT 2025

- 33.4K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

    executionThread.join();

    assertTrue(service.startUpCalled);
    assertEquals(Service.State.FAILED, service.state());
    assertThat(service.failureCause()).hasMessageThat().isEqualTo("kaboom!");
  }

  private class ThrowOnStartUpService extends AbstractExecutionThreadService {
    private boolean startUpCalled = false;

    @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 12.8K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractIdleService.java

    delegate.addListener(listener, executor);
  }

  /**
   * @since 14.0
   */
  @Override
  public final Throwable failureCause() {
    return delegate.failureCause();
  }

  /**
   * @since 15.0
   */
  @CanIgnoreReturnValue
  @Override
  public final Service startAsync() {
    delegate.startAsync();
    return this;
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 5.5K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractExecutionThreadService.java

    delegate.addListener(listener, executor);
  }

  /**
   * @since 14.0
   */
  @Override
  public final Throwable failureCause() {
    return delegate.failureCause();
  }

  /**
   * @since 15.0
   */
  @CanIgnoreReturnValue
  @Override
  public final Service startAsync() {
    delegate.startAsync();
    return this;
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 7.2K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java

          }

          @Override
          public final State state() {
            return delegate.state();
          }

          @Override
          public final Throwable failureCause() {
            return delegate.failureCause();
          }
        };
    IllegalArgumentException expected =
        assertThrows(
            IllegalArgumentException.class,

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 25.6K bytes

- Click Count (0)

Search Options