Scala 了解 NotUsed 和 Done

在本文中，我们将介绍 Scala 中的 NotUsed 和 Done 两个概念，并举例说明它们的用途和区别。

阅读更多：Scala 教程

NotUsed

在 Scala 中，NotUsed 是一个特殊的类型。它是一个表示没有实际值的标记类型。在函数式编程中，有时我们希望表示某个函数或方法不返回任何实际的值，只是进行一些副作用或者执行某个操作。这时可以使用 NotUsed 来表示。不管函数的返回值类型是什么，我们可以选择将其替换为 NotUsed。

例如，假设我们有一个函数需要读取一个文件并将其打印到控制台上，而不需要返回任何实际的结果。这时我们可以将该函数的返回类型设置为 NotUsed。下面是一个简单的示例：

import akka.stream.scaladsl.FileIO
import akka.util.ByteString
import scala.concurrent.ExecutionContext.Implicits.global

def printFileContent(filename: String): NotUsed = {
  val fileStream = FileIO.fromPath(Paths.get(filename))
  val result = fileStream.runForeach { byteString =>
    println(byteString.utf8String)
  }
  NotUsed
}

printFileContent("example.txt")

在上面的代码中，printFileContent 函数读取指定的文件并逐行打印到控制台上。该函数的返回类型是 NotUsed，表示不返回任何实际的值，只是执行打印操作。

Done

与 NotUsed 不同，Done 是一个具体的类型，表示一个已完成的操作或任务。Done 类型通常用于表示对外部系统发起的异步操作的结果。当一个异步操作执行完成后，我们可以使用 Done 类型来表示操作已成功完成。

下面是一个示例，演示了如何使用 Done 类型来表示异步操作的结果：

import akka.Done
import scala.concurrent.Future

def performAsyncOperation(): Future[Done] = {
  // 一些异步操作，如发送邮件或写入数据库等
  Future.successful(Done)
}

val result: Future[Done] = performAsyncOperation()

result.foreach { _ =>
  println("异步操作已完成")
}

在上面的代码中，performAsyncOperation 函数执行一个异步操作，并返回 Future[Done] 类型的结果。在操作成功完成后，我们可以使用 foreach 方法来处理该结果，在这个例子中打印出一条消息。

Done 类型还可以与 Akka Streams 结合使用，表示流的完成状态。当一个流完成时，我们可以使用 Done 类型来表示流已经结束。

import akka.Done
import akka.actor.ActorSystem
import akka.stream.Materializer
import akka.stream.scaladsl._

import scala.concurrent.Future

def processStream(): Future[Done] = {
  implicit val system: ActorSystem = ActorSystem("Example")
  implicit val materializer: Materializer = Materializer(system)

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

  val graph = source.to(sink)

  graph.run()
}

val result: Future[Done] = processStream()

result.foreach { _ =>
  println("流已完成")
}

上面的代码中，我们创建了一个简单的流，从1到10的范围内发射整数，然后通过 sink 将其打印到控制台上。在流完成后，我们使用 Done 类型来表示流的结束。