java - 在反应式编程中使用番石榴条纹的正确方法是什么？

Question

如何使用 guava 的 stiped 类？例如，我有以下代码：

return collector.collect(event)
    .flatMap { data -> handler.handle(obj.type(), data) }

事件具有字段 ID。我必须锁定特定 ID 的下一次执行。我怎样才能在这里使用条纹？我不能用 try/catch 块包装它，我也不能在doOnNext和doOnError块中解锁它。

标签： javakotlinlockingreactive-programmingguava