Akka Stream postStop查询节点结果状态
Query node's result status in Akka Stream postStop
在 Akka Stream GraphStageLogic 的 postStop 中，有没有办法确定该阶段是失败了还是无错地完成了？例如。得到一个 Try[Unit]，如果调用了 failStage，那将是一个 Failure，如果调用了 completeStage，则将是一个 Success。
failStage是一个final方法，所以没办法hook进去- documentation也没说什么有用的。
似乎没有。所以你需要监控所有节点自身对completeStage的调用，包括inlet/outlet个handlers.
在 Akka Stream GraphStageLogic 的 postStop 中，有没有办法确定该阶段是失败了还是无错地完成了？例如。得到一个 Try[Unit]，如果调用了 failStage，那将是一个 Failure，如果调用了 completeStage，则将是一个 Success。
failStage是一个final方法，所以没办法hook进去- documentation也没说什么有用的。
似乎没有。所以你需要监控所有节点自身对completeStage的调用，包括inlet/outlet个handlers.