我想测试我的服务,它具有以下实现:
val health: HttpRoutes[IO] = HttpRoutes.of[IO] {
case GET -> Root / "health" =>
Ok(Stream
.awakeEvery[IO](1.second)
.flatMap { _ =>
Stream
.eval[IO, ServerHealth](checkServers(checkKafkaHealth)(checkSapHealth))
.map(h => h.asJson)
})
}
我想测试该服务,我已经尝试如下:
val req = Request[IO](method = Method.GET, uri = uri"/metric/health")
val res = MetricService(config)
.health(req)
问题是,如何从响应体中获取值?