本文整理了Java中io.vertx.core.Future.cause()
方法的一些代码示例,展示了Future.cause()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Future.cause()
方法的具体详情如下:
包路径:io.vertx.core.Future
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!