Akka Streams -如何检查流是否运行成功？

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}
import scala.concurrent.ExecutionContext.Implicits.global

object StreamExample extends App {
  implicit val system = ActorSystem("my-system")
  implicit val materializer = ActorMaterializer()

  val source = Source(1 to 10)
  val sink = Sink.ignore

  val stream = source.runWith(sink)
  stream.onComplete { result =>
    result match {
      case scala.util.Success(_) => println("Stream completed successfully")
      case scala.util.Failure(exception) => println(s"Stream failed with exception: ${exception.getMessage}")
    }
    system.terminate()
  }
}