hasCauseThat - Code Search

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

    try {
      getDone(future);
      fail();
    } catch (ExecutionException e) {
      assertThat(e).hasCauseThat().isSameInstanceAs(expectedException);
    }

    try {
      getDoneFromTimeoutOverload(future);
      fail();
    } catch (ExecutionException e) {
      assertThat(e).hasCauseThat().isSameInstanceAs(expectedException);
    }
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 15.4K bytes

- Click Count (0)

github.com/google/guava

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

    assertThat(suppressed).hasLength(2);
    assertThat(suppressed[0]).hasCauseThat().isInstanceOf(IllegalStateException.class);
    assertThat(suppressed[0]).hasCauseThat().hasMessageThat().isEqualTo("run failure");

    assertThat(suppressed[1]).hasCauseThat().isInstanceOf(IllegalStateException.class);
    assertThat(suppressed[1]).hasCauseThat().hasMessageThat().isEqualTo("start failure");

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Sep 22 17:49:12 GMT 2025

- 25.5K bytes

- Click Count (0)

github.com/google/guava

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

    ValueAndCloser<?> valueAndCloser = finishToValueAndCloser(closingFuture);
    try {
      valueAndCloser.get();
      fail();
    } catch (ExecutionException expected) {
      assertThat(expected).hasCauseThat().isSameInstanceAs(exception);
    }
    valueAndCloser.closeAsync();
  }

  @Override
  void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue May 13 18:46:00 GMT 2025

- 5.7K bytes

- Click Count (0)

github.com/google/guava

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

    exec.execute(task);
    runLatch.await();
    taskLatch.countDown();

    ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    assertThat(e).hasCauseThat().isInstanceOf(IllegalStateException.class);

    assertTrue(listenerLatch.await(5, SECONDS));
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 11 21:00:51 GMT 2025

- 4.8K bytes

- Click Count (0)

github.com/google/guava

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

    ListenableFuture<String> future = asyncCallable.call();
    ExecutionException e = assertThrows(ExecutionException.class, () -> future.get());
    assertThat(e).hasCauseThat().isSameInstanceAs(expected);
  }

  @J2ktIncompatible
  @GwtIncompatible // threads
  public void testRenaming() throws Exception {
    String oldName = Thread.currentThread().getName();

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Oct 28 16:03:47 GMT 2025

- 4.4K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/cache/NullCacheTest.java

            .build(exceptionLoader(e));

    UncheckedExecutionException uee =
        assertThrows(UncheckedExecutionException.class, () -> map.getUnchecked(new Object()));
    assertThat(uee).hasCauseThat().isSameInstanceAs(e);
    assertThat(listener.isEmpty()).isTrue();
    checkEmpty(map);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 11 20:07:52 GMT 2025

- 4.6K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/cache/NullCacheTest.java

            .build(exceptionLoader(e));

    UncheckedExecutionException uee =
        assertThrows(UncheckedExecutionException.class, () -> map.getUnchecked(new Object()));
    assertThat(uee).hasCauseThat().isSameInstanceAs(e);
    assertThat(listener.isEmpty()).isTrue();
    checkEmpty(map);
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 11 20:07:52 GMT 2025

- 4.6K bytes

- Click Count (0)

github.com/google/guava

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

    ValueAndCloser<?> valueAndCloser = finishToValueAndCloser(closingFuture);
    try {
      valueAndCloser.get();
      fail();
    } catch (ExecutionException expected) {
      assertThat(expected).hasCauseThat().isSameInstanceAs(exception);
    }
    valueAndCloser.closeAsync();
  }

  @Override
  void assertBecomesCanceled(ClosingFuture<?> closingFuture) throws ExecutionException {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue May 13 18:46:00 GMT 2025

- 5.7K bytes

- Click Count (0)

github.com/google/guava

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

    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
    ExecutionException executionException =
        assertThrows(ExecutionException.class, () -> getDone(task));
    assertThat(executionException).hasCauseThat().isEqualTo(e);
  }

  @J2ktIncompatible
  @GwtIncompatible // blocking wait
  public void testCancel_interrupted() throws Exception {
    AtomicBoolean interruptedExceptionThrown = new AtomicBoolean();

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Aug 07 16:05:33 GMT 2025

- 7.2K bytes

- Click Count (0)

github.com/google/guava

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

    exec.execute(task);
    runLatch.await();
    taskLatch.countDown();

    ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    assertThat(e).hasCauseThat().isInstanceOf(IllegalStateException.class);

    assertTrue(listenerLatch.await(5, SECONDS));
    assertTrue(task.isDone());
    assertFalse(task.isCancelled());
  }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Dec 11 21:00:51 GMT 2025

- 4.8K bytes

- Click Count (0)

Search Options