HttpClientResponse freeze

HttpClientResponseFreeze.java

package eu.ydp.esa.tts.controller.impl;

import com.github.tomakehurst.wiremock.junit.WireMockRule;
import io.vertx.rxjava.core.Vertx;
import io.vertx.rxjava.core.http.HttpClientRequest;
import io.vertx.rxjava.core.http.HttpClientResponse;
import org.junit.Rule;
import org.junit.Test;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import static com.github.tomakehurst.wiremock.client.WireMock.*;
import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
import static org.assertj.core.api.Assertions.assertThat;

public class HttpClientResponseFreeze {

    @Rule
    public WireMockRule mockServer = new WireMockRule(12344);

    public CountDownLatch latch = new CountDownLatch(1);

    @Test
    public void testVertx() throws Exception {
        Vertx vertx = Vertx.vertx();

        stubFor(post(urlPathEqualTo("/test"))
            .willReturn(aResponse()
                .withStatus(500)));

        HttpClientRequest httpClientRequest = vertx.createHttpClient()
            .postAbs("http://localhost:12344/test");
        httpClientRequest
            .toObservable()
            .flatMap(HttpClientResponse::toObservable)
            .subscribe(v -> {
                latch.countDown();
            });

        httpClientRequest.end();
        latch.await(5, TimeUnit.SECONDS);
        assertThat(latch.getCount()).isEqualTo(0);
    }
}