package cx.lehmann.vertx;

import org.junit.Test;
import org.junit.runner.RunWith;

import io.vertx.core.logging.Logger;
import io.vertx.core.logging.LoggerFactory;
import io.vertx.ext.unit.Async;
import io.vertx.ext.unit.TestContext;
import io.vertx.ext.unit.junit.VertxUnitRunner;

@RunWith(VertxUnitRunner.class)
public class AsyncTest {
  private static final Logger log = LoggerFactory.getLogger(AsyncTest.class);
  private TestClient client = new TestClient();

  @Test
  public void asyncTest(TestContext theContext) {
    Async submit = theContext.async(9);
    String submission = "";
    for (int i = 0; i < 9; i++) {
      final int fi = i;
      client.submitJob(submission, theContext.asyncAssertSuccess(job -> {
        log.info("success " + fi);
        submit.countDown();
      }));
    }
    log.info("await");
    submit.await();
    log.info("finished");
  }
}