使用vert.x rxjava2和Mockito模拟http响应

<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-core</artifactId>
    <version>4.1.3</version>
</dependency>
<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-web</artifactId>
    <version>4.1.3</version>
</dependency>
<dependency>
    <groupId>io.reactivex.rxjava2</groupId>
    <artifactId>rxjava</artifactId>
    <version>2.2.21</version>
</dependency>
<dependency>
    <groupId>org.mockito</groupId>
    <artifactId>mockito-core</artifactId>
    <version>3.12.4</version>
    <scope>test</scope>
</dependency>

import io.vertx.core.Vertx;
import io.vertx.core.http.HttpServer;
import io.vertx.core.http.HttpServerResponse;

Vertx vertx = Vertx.vertx();
HttpServer server = vertx.createHttpServer();

import io.vertx.ext.web.Router;
import io.vertx.ext.web.RoutingContext;

Router router = Router.router(vertx);

router.route("/api").handler(this::handleApiRequest);

private void handleApiRequest(RoutingContext routingContext) {
    // 处理HTTP请求的逻辑
    HttpServerResponse response = routingContext.response();
    response.putHeader("content-type", "application/json").end("{\"message\":\"Hello, World!\"}");
}

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

Observable<String> observable = Observable.just("Hello, World!")
        .subscribeOn(Schedulers.io());

import static org.mockito.Mockito.*;

HttpServerResponse response = mock(HttpServerResponse.class);
when(response.putHeader(anyString(), anyString())).thenReturn(response);
when(response.end(anyString())).thenReturn(response);

// 在测试中验证HTTP响应的行为
verify(response).putHeader("content-type", "application/json");
verify(response).end("{\"message\":\"Hello, World!\"}");