不完全了解来源。延迟方法或akka流文档中存在错误

我正在阅读关于akka stream的文档 KillSwitch 他们用一个例子来说明 KillSwitch.shutdown 方法:

val countingSrc = Source(Stream.from(1)).delay(1.second, DelayOverflowStrategy.backpressure)
val lastSnk = Sink.last[Int]

val (killSwitch, last) = countingSrc
  .viaMat(KillSwitches.single)(Keep.right)
  .toMat(lastSnk)(Keep.both)
  .run()

doSomethingElse()

killSwitch.shutdown()

Await.result(last, 1.second) shouldBe 2

我无法理解为什么预期结果应该是2。 正如我看到的这个例子,流被设置为1秒延迟。暂停时 shutdown() 调用,以便kill开关在延迟完成之前通知流关闭。我不明白为什么流的前2个元素会被释放并传递到接收器。

你能帮我解释一下吗?

注意:如果运行此示例,我会得到预期的以下异常:

Exception in thread "main" java.util.NoSuchElementException: last of empty stream
    at akka.stream.scaladsl.Sink$.$anonfun$last$3(Sink.scala:181)