failureCause - Code Search

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

  }

  public void testFailed() {
    Exception failureCause = new Exception();
    try {
      getDone(immediateFailedFuture(failureCause));
      fail();
    } catch (ExecutionException expected) {
      assertThat(expected).hasCauseThat().isEqualTo(failureCause);
    }
  }

  public void testCancelled() throws ExecutionException {
    try {

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 2.2K bytes

- Viewed (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);
  }

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 29.3K bytes

- Viewed (0)

github.com/google/guava

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

  }

  public void testFailed() {
    Exception failureCause = new Exception();
    try {
      getDone(immediateFailedFuture(failureCause));
      fail();
    } catch (ExecutionException expected) {
      assertThat(expected).hasCauseThat().isEqualTo(failureCause);
    }
  }

  public void testCancelled() throws ExecutionException {
    try {

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Tue Feb 13 14:28:25 GMT 2024

- 2.2K bytes

- Viewed (0)

github.com/google/guava

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

        return STOPPING;
      } else {
        return state;
      }
    }

    /** @see Service#failureCause() */
    Throwable failureCause() {
      checkState(
          state == FAILED,
          "failureCause() is only valid if the service has failed, service is %s",
          state);

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Fri May 12 18:32:03 GMT 2023

- 20.4K bytes

- Viewed (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);
  }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 29.3K bytes

- Viewed (0)

github.com/google/guava

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

  public final void addListener(Listener listener, Executor executor) {
    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;
  }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Apr 17 13:59:28 GMT 2023

- 5.3K bytes

- Viewed (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

Java

- Registered: Fri Apr 12 12:43:09 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 12.7K bytes

- Viewed (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

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Sep 06 17:04:31 GMT 2023

- 12.7K bytes

- Viewed (0)

github.com/google/guava

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

  public final void addListener(Listener listener, Executor executor) {
    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;
  }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Dec 13 19:45:20 GMT 2023

- 7.6K bytes

- Viewed (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,

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Oct 02 17:20:27 GMT 2023

- 23.2K bytes

- Viewed (0)

Search Options