Scalatest AsyncFunSuite vs FunSuite

AsyncFunSuiteExample.scala

  // async suite
  test("listen for one message when subscribed to topics regex") {
    val producer = KafkaProducer[String,String](producerCfg, io)
    val consumer = KafkaConsumerObservable[String,String](consumerCfg, topicsRegex).executeOn(io)

    // Publishing one message
    val flow = for {
      _ <- producer.send(topicMatchingRegex, "test-message")
      first <- consumer.take(1).map(_.value()).firstL
    } yield {
      first
    }

    flow.runAsync.map { result =>
      assert(result === "test-message2")
    }
  }
  
  //sync
  test("listen for one message when subscribed to topics regex") {
    val producer = KafkaProducer[String,String](producerCfg, io)
    val consumer = KafkaConsumerObservable[String,String](consumerCfg, topicsRegex).executeOn(io)
    try {
      // Publishing one message
      val send = producer.send(topicMatchingRegex, "test-message")
      Await.result(send.runAsync, 30.seconds)

      val first = consumer.take(1).map(_.value()).firstL
      val result = Await.result(first.runAsync, 30.seconds)
      assert(result === "test-message")
    }
    finally {
      Await.result(producer.close().runAsync, Duration.Inf)
    }
  }