scala - OverflowStrategyでストリームにドロップされた要素を印刷する方法は?

Question

OverflowStrategy.dropHeadまたはOverflowStrategy.dropTailを使用しているときに、ストリームのドロップされた要素を出力する方法はありますか?

Answer 1

akka.stream.impl.ActorRefSourceActorが役立つ場合、次の 2 つ caseの s がありreceiveます。

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

ドロップされる前に要素を印刷する可能性を消してしまうと思います。