Testing

    /** Runs `v` to its end on the Kyo scheduler (at most 60 s). */
    private def run[A](v: => A < (Async & Scope))(using Frame): A =
        import AllowUnsafe.embrace.danger
        KyoApp.Unsafe.runAndBlock(60.seconds)(v).getOrThrow

    private def start(ui: => UI < (Async & Scope))(using
        Frame,
    ): Headless < (Async & Scope) =
      Headless.start(60, 10)(_ => ui)

    /** Waits until the screen shows `text`, at most 10 s. */
    private def shows(h: Headless, text: String)(using Frame): Boolean < Async =
      h.awaitScreen(_.contains(text), 10.seconds)

    test(
      "search: the results of the quiet query; a new query gives new results",
    ) {
      val ok = run {
        for
            h     <- start(Recipes.search(q => Chunk(s"$q-1", s"$q-2")))
            idle  <- shows(h, "type to search")
            _     <- h.typeText("kyo")
            found <- shows(h, "found: kyo-1, kyo-2")
            _     <- h.key(Keyboard.Backspace)
            again <- shows(h, "found: ky-1, ky-2")
        yield (idle, found, again)
      }
      assertEquals(ok, (true, true, true))
    }

    test("progress: 100 writes in a row; the last value shows") {
      val ok = run {
        for
            done <- Signal.initRef(0)
            h    <- start(Recipes.progress(done))
            _    <- Kyo.foreach(1 to 100)(done.set)
            last <- shows(h, "100 %")
        yield last
      }
      assert(ok)
    }