如何在Akka actor中等待文件上传流完成

import akka.stream.scaladsl.{FileIO, Sink}
import akka.actor.Actor

class MyActor extends Actor {
  def receive: Receive = {
    case fileStream: InputStream =>
      // 将文件上传流转换为Akka Stream的Source
      val source = FileIO.fromInputStream(() => fileStream)
      
      // 创建一个Sink来消费文件上传流
      val sink = Sink.ignore
      
      // 运行Akka Stream流水线
      val future = source.runWith(sink)
      
      // 等待文件上传流完成
      val result = Await.result(future, Duration.Inf)
      
      // 文件上传流完成后的处理逻辑
      // ...
  }
}

val system = ActorSystem("mySystem")
val myActor = system.actorOf(Props[MyActor])

// 假设fileStream是文件上传流
myActor ! fileStream