io.vertx.ext.unit.TestContext.async()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(6.9k)|赞(0)|评价(0)|浏览(118)

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

TestContext.async介绍

暂无

代码示例

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

@Before
public void before(TestContext context) {
  vertx = Vertx.vertx();
  Async async = context.async();
  vertx.deployVerticle(TestVerticle.class.getName(), context.asyncAssertSuccess(event -> async.complete()));
}

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

@Test
public void test(TestContext testContext) {
  HttpClient client =
      vertx.createHttpClient(new HttpClientOptions()
          .setConnectTimeout(10000));
  Async async = testContext.async();
  client.getNow(PORT, "127.0.0.1", "/test", testContext.asyncAssertSuccess(httpClientResponse -> {
   testContext.assertEquals(HttpURLConnection.HTTP_NO_CONTENT, httpClientResponse.statusCode());
   async.complete();
  }));
}

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

@Test
 public void testTimingOut(TestContext context) {
  context.async();
 }
}

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

@Test
 public void testLoadingFromEnvironmentVariables(TestContext context) {
  Async async = context.async();
  getJsonConfiguration(vertx, store, ar -> {
   assertThat(ar.succeeded()).isTrue();
   assertThat(ar.result().getString(KEY_1)).isEqualTo(VAL_1);
   assertThat(ar.result().getString(KEY_2)).isEqualTo(VAL_2);
   async.complete();
  });
 }
}

代码示例来源:origin: de.braintags/netrelay

@Test
public void testProcessor(TestContext context) throws Exception {
 try {
  Async async = context.async();
  DemoProcessor.async = async;
  context.assertEquals(DEMO_PROPERTY, demoProperty, "init does not seem to be handled");
  async.await(WAITTIME);
  context.assertTrue(eventProcessed, "the event wasn't processed");
 } catch (Exception e) {
  context.fail(e);
 }
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testReleaseConnectionOnSetRollback(TestContext ctx) {
 Async async = ctx.async();
 connector.accept(ctx.asyncAssertSuccess(conn -> {
  conn.query("SELECT whatever from DOES_NOT_EXIST", ctx.asyncAssertFailure(result -> {
   // Try acquire a connection
   pool.getConnection(ctx.asyncAssertSuccess(v2 -> {
    async.complete();
   }));
  }));
 }));
}

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

@Test
public void testLoadingFromAJsonArrayFile(TestContext context) {
 Async async = context.async();
 store = factory.create(vertx, new JsonObject().put("path", "src/test/resources/file/array.json"));
 getJsonConfiguration(vertx, store, ar -> {
  assertThat(ar.failed()).isTrue();
  async.complete();
 });
}

代码示例来源:origin: de.braintags/NetRelayController

@Test
public void testProcessor(TestContext context) throws Exception {
 try {
  Async async = context.async();
  DemoMailProcessor.async = async;
  context.assertEquals(DEMO_PROPERTY, demoProperty, "init does not seem to be handled");
  async.await();
  context.assertTrue(eventProcessed, "the event wasn't processed");
 } catch (Exception e) {
  context.fail(e);
 }
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testConnectInvalidPassword(TestContext ctx) {
 Async async = ctx.async();
 options.setPassword("incorrect");
 connector.accept(ctx.asyncAssertFailure(conn -> {
  ctx.assertEquals("password authentication failed for user \"postgres\"", conn.getMessage());
  async.complete();
 }));
}

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

@Test
public void testLoadingFromEnvWithNullKeySet(TestContext context) {
 Async async = context.async();
 store = factory.create(vertx, new JsonObject().put("keys", (JsonArray) null));
 getJsonConfiguration(vertx, store, ar -> {
  assertThat(ar.succeeded()).isTrue();
  assertThat(ar.result().getString("PATH")).isNotNull();
  async.complete();
 });
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testConnectInvalidDatabase(TestContext ctx) {
 Async async = ctx.async();
 options.setDatabase("blah_db");
 connector.accept(ctx.asyncAssertFailure(conn -> {
  ctx.assertEquals("database \"blah_db\" does not exist", conn.getMessage());
  async.complete();
 }));
}

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

@Test
 public void testMethod(TestContext context) {
  requestCount.set(0);
  Async async = context.async();
  vertx.createHttpClient().getNow(8080, "localhost", "/", resp -> {
   async.complete();
  });
 }
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testEmptyBatch(TestContext ctx) {
 Async async = ctx.async();
 PgClient.connect(vertx, options, ctx.asyncAssertSuccess(conn -> {
  List<Tuple> batch = new ArrayList<>();
  conn.preparedBatch("INSERT INTO Test (id, val) VALUES ($1, $2)", batch, ctx.asyncAssertSuccess(result -> {
   async.complete();
  }));
 }));
}

代码示例来源:origin: io.vertx/vertx-web-templ-mvel

@Test
public void testNoSuchTemplate(TestContext should) {
 final Async test = should.async();
 TemplateEngine engine = MVELTemplateEngine.create(vertx);
 engine.render(new JsonObject(), "nosuchtemplate.templ", render -> {
  should.assertFalse(render.succeeded());
  test.complete();
 });
 test.await();
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testConnectNonSSLServer(TestContext ctx) {
 Async async = ctx.async();
 options.setSslMode(SslMode.REQUIRE).setTrustAll(true);
 connector.accept(ctx.asyncAssertFailure(err -> {
  ctx.assertEquals("Postgres Server does not handle SSL connection", err.getMessage());
  async.complete();
 }));
}

代码示例来源:origin: io.vertx/vertx-web-templ-rocker

@Test
public void testNoSuchTemplate(TestContext should) {
 final Async test = should.async();
 TemplateEngine engine = RockerTemplateEngine.create();
 final JsonObject context = new JsonObject();
 engine.render(context, "nosuchtemplate.rocker.html", render -> {
  should.assertFalse(render.succeeded());
  test.complete();
 });
 test.await();
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testInsert(TestContext ctx) {
 Async async = ctx.async();
 connector.accept(ctx.asyncAssertSuccess(client -> {
  deleteFromTestTable(ctx, client, () -> {
   client.query("INSERT INTO Test (id, val) VALUES (1, 'Whatever')", ctx.asyncAssertSuccess(r1 -> {
    ctx.assertEquals(1, r1.rowCount());
    async.complete();
   }));
  });
 }));
}

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

@Test
public void testOverloading(TestContext tc) {
 System.setProperty("key", "new-value");
 retriever = ConfigRetriever.create(vertx,
  addStores(new ConfigRetrieverOptions()));
 Async async = tc.async();
 retriever.getConfig(ar -> {
  assertThat(ar.result().getString("key")).isEqualToIgnoringCase("new-value");
  async.complete();
 });
}

代码示例来源:origin: reactiverse/reactive-pg-client

@Test
public void testClose(TestContext ctx) {
 Async async = ctx.async();
 connector.accept(ctx.asyncAssertSuccess(conn -> {
  conn.closeHandler(v -> {
   async.complete();
  });
  conn.close();
 }));
}

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

@Test
public void testReversedOverloading(TestContext tc) {
 System.setProperty("key", "new-value");
 retriever = ConfigRetriever.create(vertx, addReversedStores(new ConfigRetrieverOptions()));
 Async async = tc.async();
 retriever.getConfig(ar -> {
  assertThat(ar.result().getString("key")).isEqualToIgnoringCase("value");
  async.complete();
 });
}

相关文章