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

TestContext.assertEquals介绍

暂无

代码示例

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

@Override
 public void complete(List<String> candidates) {
  context.assertEquals(Collections.emptyList(), candidates);
  async.complete();
 }
});

代码示例来源：origin: PegaSysEng/pantheon

@Test
public void authInfoWithoutUsernameShouldFailAuthentication(final TestContext context) {
 JsonObject authInfo = new JsonObject().put("password", "foo");
 tomlAuth.authenticate(
   authInfo,
   context.asyncAssertFailure(
     th -> context.assertEquals("No username provided", th.getMessage())));
}

代码示例来源：origin: de.braintags/vertx-pojo-mapper-common-test

@Test
public void testFindByEnumContains(TestContext context) {
 createDemoRecords(context);
 IQuery<EnumRecord> query = getDataStore(context).createQuery(EnumRecord.class);
 query.field("enumEnum").contains("IN");
 List<EnumRecord> list = (List<EnumRecord>) findAll(context, query);
 list.forEach(sm -> logger.info(sm.enumEnum));
 context.assertEquals(1, list.size(), "incorrect result");
}

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

@Test
public void createDefaultSession(TestContext tc) {
 ctx.writeClient().createSession(tc.asyncAssertSuccess(id -> {
  ctx.writeClient().infoSession(id, tc.asyncAssertSuccess(session -> {
   tc.assertEquals(id, session.getId());
   tc.assertEquals(ctx.nodeName(), session.getNode());
   ctx.writeClient().destroySession(id, tc.asyncAssertSuccess());
  }));
 }));
}

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

@Test
public void testDuplicateRegistration(TestContext context) {
 CommandRegistry registry = CommandRegistry.getShared(vertx);
 Command a = CommandBuilder.command("a").build(vertx);
 Command b = CommandBuilder.command("b").build(vertx);
 registry.registerCommand(a, context.asyncAssertSuccess(reg -> {
  registry.registerCommands(Arrays.asList(a, b), context.asyncAssertFailure(err -> {
   context.assertEquals(1, registry.commands().size());
   context.assertNotNull(registry.getCommand("a"));
  }));
 }));
}

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

private void assertReceiveMessages(TestContext ctx, String topicName, int numMessages) {
 Async done = ctx.async();
 AtomicInteger seq = new AtomicInteger();
 kafkaCluster.useTo().consumeStrings(() -> seq.get() < numMessages, done::complete, Collections.singleton(topicName), record -> {
  int count = seq.getAndIncrement();
  ctx.assertEquals("key-" + count, record.key());
  ctx.assertEquals("value-" + count, record.value());
  ctx.assertEquals("header_value-" + count, new String(record.headers().headers("header_key").iterator().next().value()));
 });
}

代码示例来源：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: PegaSysEng/pantheon

@Test
public void authInfoWithoutPasswordShouldFailAuthentication(final TestContext context) {
 JsonObject authInfo = new JsonObject().put("username", "foo");
 tomlAuth.authenticate(
   authInfo,
   context.asyncAssertFailure(
     th -> context.assertEquals("No password provided", th.getMessage())));
}

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

@Test
public void testOutBinaryTrue(TestContext context) throws Exception {
 startTelnet(context, new TelnetTermOptions().setOutBinary(true), term -> {
  term.write("\u20AC");
 });
 client.addOptionHandler(new WindowSizeOptionHandler(10, 20, false, false, true, false));
 client.connect("localhost", server.actualPort());
 InputStream in = client.getInputStream();
 context.assertEquals(226, in.read());
 context.assertEquals(130, in.read());
 context.assertEquals(172, in.read());
}

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

@Override
 public void complete(List<String> candidates) {
  context.assertEquals(Collections.emptyList(), candidates);
  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: PegaSysEng/pantheon

@Test
public void authInfoWithAbsentUserShouldFailAuthentication(final TestContext context) {
 JsonObject authInfo = new JsonObject().put("username", "foo").put("password", "foo");
 tomlAuth.authenticate(
   authInfo,
   context.asyncAssertFailure(th -> context.assertEquals("User not found", th.getMessage())));
}

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

@Test
public void mailTestMissingNL(TestContext testContext) {
 this.testContext=testContext;
 MailMessage message = exampleMessage();
 // the protocol adds a newline at the end if there isn't one
 message.setText(".");
 testSuccess(mailClientLogin(), message, () -> {
  final MimeMessage mimeMessage = wiser.getMessages().get(0).getMimeMessage();
  testContext.assertEquals(".\n", TestUtils.conv2nl(TestUtils.inputStreamToString(mimeMessage.getInputStream())));
 });
}

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

@Override
 public void complete(List<String> candidates) {
  context.assertEquals(Collections.emptyList(), candidates);
  async.complete();
 }
});

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

@Test
public void testBusSendReplyTimeout(TestContext context) {
 Async consumerAsync = context.async();
 String result = assertBusSend(context, "bus-send --reply --timeout 50 the_address the_message", msg -> {
  context.assertEquals("the_message", msg.body());
  consumerAsync.complete();
 });
 context.assertEquals("Error: Timed out after waiting 50(ms) for a reply. address: __vertx.reply.1, repliedAddress: the_address\n", result);
}

代码示例来源：origin: PegaSysEng/pantheon

@Test
public void passwordMismatchShouldFailAuthentication(final TestContext context) {
 JsonObject authInfo = new JsonObject().put("username", "userA").put("password", "foo");
 tomlAuth.authenticate(
   authInfo,
   context.asyncAssertFailure(
     th -> context.assertEquals("Invalid password", th.getMessage())));
}

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

@Override
 public void complete(List<String> candidates) {
  context.assertEquals(Arrays.asList("bar", "baz"), candidates.stream().sorted().collect(Collectors.toList()));
  async.complete();
 }
});