将列表转换为Akka Stream中的地图

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl._

import scala.concurrent.Future

object ListToMapExample extends App {
  implicit val system = ActorSystem("list-to-map-example")
  implicit val materializer = ActorMaterializer()
  implicit val executionContext = system.dispatcher

  // 输入列表
  val inputList = List(("key1", "value1"), ("key2", "value2"), ("key3", "value3"))

  // 转换操作
  val convertToList: Flow[(String, String), (String, String), NotUsed] = Flow[(String, String)].map {
    case (key, value) => (key, value)
  }

  // 输出地图
  val outputMap: Sink[(String, String), Future[Map[String, String]]] = Sink.fold[Map[String, String], (String, String)](Map.empty) {
    case (map, (key, value)) => map + (key -> value)
  }

  // 构建流处理图
  val graph = Source(inputList)
    .via(convertToList)
    .toMat(outputMap)(Keep.right)

  // 运行流处理图
  val result: Future[Map[String, String]] = graph.run()

  result.foreach { map =>
    println(map)
  }

  // 关闭Actor系统
  result.onComplete(_ => system.terminate())
}