datasourcex-kotest

object :
          FunSpec(
              {
                // Starts a Liberator in a Testcontainers container for the lifetime of the spec.
                val liberator = install(LiberatorContainerExtension())

                test("fetches a record from the containerised Liberator") {
                  val connection = liberator.connect("admin")
                  connection.connect()
                  connection.awaitConnected()

                  val info =
                      connection.getSubject(Subject("SYSTEM", "INFO")).filterIsUpdate().first()
                  println(info)

                  connection.disconnect()
                }
              },
          ) {}