FS2 流:测试 FS2 服务器

Question

我有一个这样的流：

val server = for {
  _ <- Stream.eval(initTasks)
  serverBinding <- Stream.eval(...)
} yield serverBinding

我知道为了运行它，我应该做这样的事情：

server
  .compile
  .drain
  .unsafeRunAsync(_ => ())

现在，我想为此服务器编写单元测试，但我只能在服务器全部设置完毕时运行测试。目前，在我的beforeAll块中，我有：

testServer
  .interruptWhen(shutdownSignal)
  .compile
  .drain
  .unsafeRunAsync(_ => ())
Thread.sleep(5000)

在我的afterAll块中，我有：

shutdownSignal.set(true).unsafeRunSync()

在我的测试后关闭服务器。

我

想知道我是否可以使用信号来实现我的既定目标，以便我可以以某种方式"等待"信号，以便仅在信号上升后运行测试。或者，我很想知道这样做的通用/惯用方法。

Answer 1

fs2 有一个名为 Promise 的结构，可用于此目的。它现已弃用，但可以使用 Cat's Deferred。因此，在流上运行compile.drain之前，我们可以使流完成承诺/延期值，然后在beforeAll中我们可以等待其值。