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

Future.isComplete介绍

[英]Has the future completed?

It's completed if it's either succeeded or failed.
[中]未来完成了吗？
如果它成功或失败，那么它就完成了。

代码示例

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

@Override
public boolean isComplete(int index) {
 return future(index).isComplete();
}

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

handler.handle(ar.result());
} catch (Throwable err) {
 if (next.isComplete()) {
  throw err;

代码示例来源：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

} else {
 exceptionHandler(err -> {
  if (!fut.isComplete()) {
   fut.fail(err);
  if (!fut.isComplete()) {
   fut.complete();

代码示例来源：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 testResolveFutureToHandler() {
 Consumer<Handler<AsyncResult<String>>> consumer = handler -> {
  handler.handle(Future.succeededFuture("the-result"));
 };
 Future<String> fut = Future.future();
 consumer.accept(fut);
 assertTrue(fut.isComplete());
 assertTrue(fut.succeeded());
 assertEquals("the-result", fut.result());
}

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

AtomicReference<Future<String>> ref = new AtomicReference<>();
Future<String> f2 = Future.future(f1 -> {
 assertFalse(f1.isComplete());
 count.incrementAndGet();
 ref.set(f1);

代码示例来源：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 boolean isComplete() {
 return future.isComplete();
}

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

@Override
public void handle(Throwable cause) {
 if (!state.isComplete()) {
  state.fail(cause);
 }
}

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

resp.pause();
resp.handler(buff -> {
 if (whenFull.isComplete()) {
  assertSame(ctx, Vertx.currentContext());
 } else {

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

@Override
public boolean isComplete(int index) {
 return future(index).isComplete();
}

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

@Override
public void end() {
 if (!state.isComplete()) {
  T result;
  if (buffer.length() > 0) {
   try {
    result = decoder.apply(buffer);
   } catch (Throwable t) {
    state.fail(t);
    return;
   }
  } else {
   result = null;
  }
  state.complete(result);
 }
}

代码示例来源：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 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: io.vertx/vertx-core

@Test
public void testResolveFutureToHandler() {
 Consumer<Handler<AsyncResult<String>>> consumer = handler -> {
  handler.handle(Future.succeededFuture("the-result"));
 };
 Future<String> fut = Future.future();
 consumer.accept(fut);
 assertTrue(fut.isComplete());
 assertTrue(fut.succeeded());
 assertEquals("the-result", fut.result());
}