1

我想测试我的服务,它具有以下实现:

  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)

问题是,如何从响应体中获取值?

4

0 回答 0