scala - 如何使用 OverflowStrategy 在流中打印丢弃的元素？

Question

使用OverflowStrategy.dropHead或OverflowStrategy.dropTail时，有没有办法打印流的丢弃元素？

Answer 1

如果akka.stream.impl.ActorRefSourceActor可以提供任何帮助，则有以下两个 ：casereceive

    case DropHead ⇒
      buffer.dropHead()
      buffer.enqueue(elem)
    case DropTail ⇒
      buffer.dropTail()
      buffer.enqueue(elem)

我认为它消除了在丢弃之前打印出元素的可能性。