如何突然停止akka流的Runnable Graph？

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.KillSwitches
import akka.stream.scaladsl.{Flow, Keep, Sink, Source}

object StopAkkaStreamExample extends App {
  implicit val system: ActorSystem = ActorSystem("StopAkkaStreamExample")
  implicit val materializer: ActorMaterializer = ActorMaterializer()

  // 创建一个KillSwitch对象
  val killSwitch = KillSwitches.single[Int]

  // 创建一个简单的流，每秒生成一个递增的数字
  val source = Source.tick(0, 1, 0)
    .viaMat(killSwitch.flow, Keep.right) // 将KillSwitch对象添加到流中
    .map { i =>
      println(i)
      i
    }

  // 创建一个Sink，用于消费流中的元素
  val sink = Sink.ignore

  // 运行流，并保留原始流的引用
  val graph = source.to(sink).run()

  // 模拟停止流的条件
  Thread.sleep(5000)

  // 停止流
  killSwitch.shutdown()

  // 等待流完成
  graph.onComplete(_ => system.terminate())
}