HttpTest.java

HttpTest.java

import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

import org.junit.Test;

import io.vertx.core.http.HttpClient;
import io.vertx.core.http.HttpClientOptions;
import io.vertx.core.http.HttpClientRequest;
import io.vertx.core.http.HttpServer;
import io.vertx.core.logging.Logger;
import io.vertx.core.logging.LoggerFactory;
import io.vertx.test.core.VertxTestBase;

public class HttpTest extends VertxTestBase {
  private static final int HTTP_PORT = 12345;
  private SomeClass fixture;

  @Test
  public void testHandle() {
    final Logger logger=LoggerFactory.getLogger(this.getClass());

    fixture=new SomeClass(vertx);

    final HttpServer server=vertx.createHttpServer().requestHandler(req -> {
      logger.info("calling fixture.handler");
      fixture.handle(req);
    }).listen(HTTP_PORT);

    HttpClientOptions options = new HttpClientOptions().setDefaultHost("localhost").setDefaultPort(HTTP_PORT);
    HttpClient httpClient=vertx.createHttpClient(options);
    AtomicInteger statusCode=new AtomicInteger(0);
    AtomicReference<String> result=new AtomicReference<>("");
    HttpClientRequest cReq=httpClient.get("/url", cResp -> {
      statusCode.set(cResp.statusCode());
      cResp.bodyHandler(buffer -> result.set(buffer.toString()));
      cResp.endHandler(v -> {
        server.close();
        assertEquals(200,statusCode.get());
        assertEquals("finished",result.get());
        testComplete();
      });
    });
    cReq.end();
    await();
  }

}