本文整理了Java中io.vertx.core.Future.cause()方法的一些代码示例，展示了Future.cause()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Future.cause()方法的具体详情如下：
包路径：io.vertx.core.Future
类名称：Future
方法名：cause

Future.cause介绍

[英]A Throwable describing failure. This will be null if the operation succeeded.
[中]描述失败的可丢弃的东西。如果操作成功，该值将为空。

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public Throwable cause(int index) {
 return future(index).cause();
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public Throwable cause() {
 return fut.cause();
}

代码示例来源：origin: eclipse-vertx/vert.x

public void handle(Future<T> ar) {
 if (ar.succeeded()) {
  complete(ar.result());
 } else {
  fail(ar.cause());
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

Throwable assertFailed() {
  assertTrue(future.isComplete());
  assertFalse(future.succeeded());
  assertTrue(future.failed());
  assertEquals(null, future.result());
  assertEquals(1, count.get());
  AsyncResult<T> ar = result.get();
  assertNotNull(ar);
  assertFalse(ar.succeeded());
  assertTrue(ar.failed());
  assertNull(ar.result());
  return future.cause();
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

void assertSucceeded(T expected) {
 assertTrue(future.isComplete());
 assertTrue(future.succeeded());
 assertFalse(future.failed());
 assertNull(future.cause());
 assertEquals(expected, future.result());
 assertEquals(1, count.get());
 AsyncResult<T> ar = result.get();
 assertNotNull(ar);
 assertTrue(ar.succeeded());
 assertFalse(ar.failed());
 assertNull(ar.cause());
 assertEquals(expected, future.result());
}

代码示例来源：origin: eclipse-vertx/vert.x

void assertNotCompleted() {
 assertFalse(future.isComplete());
 assertFalse(future.succeeded());
 assertFalse(future.failed());
 assertNull(future.cause());
 assertNull(future.result());
 assertEquals(0, count.get());
 assertNull(result.get());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testFailFutureToHandler() {
 Throwable cause = new Throwable();
 Consumer<Handler<AsyncResult<String>>> consumer = handler -> {
  handler.handle(Future.failedFuture(cause));
 };
 Future<String> fut = Future.future();
 consumer.accept(fut);
 assertTrue(fut.isComplete());
 assertTrue(fut.failed());
 assertEquals(cause, fut.cause());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testFailedMapperFutureRecover() {
 Future<String> f = Future.future();
 Future<String> r = f.recover(t -> {
  throw new RuntimeException("throw");
 });
 f.fail("recovered");
 assertTrue(r.failed());
 assertEquals(r.cause().getMessage(), "throw");
}

代码示例来源：origin: resilience4j/resilience4j

@Test
public void shouldExecuteFutureAndReturnWithException() {
  // Given
  CircuitBreaker circuitBreaker = CircuitBreaker.ofDefaults("testName");
  CircuitBreaker.Metrics metrics = circuitBreaker.getMetrics();
  assertThat(metrics.getNumberOfBufferedCalls()).isEqualTo(0);
  // Given the HelloWorldService throws an exception
  BDDMockito.given(helloWorldService.returnHelloWorld()).willReturn(Future.failedFuture(new RuntimeException("BAM!")));
  //When
  Future<String> future =  VertxCircuitBreaker.executeFuture(circuitBreaker, helloWorldService::returnHelloWorld);
  //Then
  assertThat(future.failed()).isTrue();
  assertThat(future.cause()).isInstanceOf(RuntimeException.class);
  assertThat(metrics.getNumberOfBufferedCalls()).isEqualTo(1);
  assertThat(metrics.getNumberOfFailedCalls()).isEqualTo(1);
  assertThat(metrics.getNumberOfSuccessfulCalls()).isEqualTo(0);
  // Then the helloWorldService should be invoked 1 time
  BDDMockito.then(helloWorldService).should(Mockito.times(1)).returnHelloWorld();
}

代码示例来源：origin: resilience4j/resilience4j

assertThat(future.cause()).isInstanceOf(CircuitBreakerOpenException.class);
assertThat(metrics.getNumberOfBufferedCalls()).isEqualTo(2);
assertThat(metrics.getNumberOfFailedCalls()).isEqualTo(2);

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testStateAfterCompletion() {
 Object foo = new Object();
 Future<Object> future = Future.succeededFuture(foo);
 assertTrue(future.succeeded());
 assertFalse(future.failed());
 assertTrue(future.isComplete());
 assertEquals(foo, future.result());
 assertNull(future.cause());
 Exception cause = new Exception();
 future = Future.failedFuture(cause);
 assertFalse(future.succeeded());
 assertTrue(future.failed());
 assertTrue(future.isComplete());
 assertNull(future.result());
 assertEquals(cause, future.cause());
}

代码示例来源：origin: vert-x3/vertx-web

@Override
public Throwable cause() {
 return future.cause();
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public Throwable cause() {
 return fut.cause();
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public Throwable cause(int index) {
 return future(index).cause();
}

代码示例来源：origin: io.vertx/vertx-core

public void handle(Future<T> ar) {
 if (ar.succeeded()) {
  complete(ar.result());
 } else {
  fail(ar.cause());
 }
}

代码示例来源：origin: io.vertx/vertx-core

Throwable assertFailed() {
  assertTrue(future.isComplete());
  assertFalse(future.succeeded());
  assertTrue(future.failed());
  assertEquals(null, future.result());
  assertEquals(1, count.get());
  AsyncResult<T> ar = result.get();
  assertNotNull(ar);
  assertFalse(ar.succeeded());
  assertTrue(ar.failed());
  assertNull(ar.result());
  return future.cause();
 }
}

代码示例来源：origin: io.vertx/vertx-core

void assertSucceeded(T expected) {
 assertTrue(future.isComplete());
 assertTrue(future.succeeded());
 assertFalse(future.failed());
 assertNull(future.cause());
 assertEquals(expected, future.result());
 assertEquals(1, count.get());
 AsyncResult<T> ar = result.get();
 assertNotNull(ar);
 assertTrue(ar.succeeded());
 assertFalse(ar.failed());
 assertNull(ar.cause());
 assertEquals(expected, future.result());
}

代码示例来源：origin: io.vertx/vertx-core

void assertNotCompleted() {
 assertFalse(future.isComplete());
 assertFalse(future.succeeded());
 assertFalse(future.failed());
 assertNull(future.cause());
 assertNull(future.result());
 assertEquals(0, count.get());
 assertNull(result.get());
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testFailedMapperFutureRecover() {
 Future<String> f = Future.future();
 Future<String> r = f.recover(t -> {
  throw new RuntimeException("throw");
 });
 f.fail("recovered");
 assertTrue(r.failed());
 assertEquals(r.cause().getMessage(), "throw");
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testFailFutureToHandler() {
 Throwable cause = new Throwable();
 Consumer<Handler<AsyncResult<String>>> consumer = handler -> {
  handler.handle(Future.failedFuture(cause));
 };
 Future<String> fut = Future.future();
 consumer.accept(fut);
 assertTrue(fut.isComplete());
 assertTrue(fut.failed());
 assertEquals(cause, fut.cause());
}