在我的一个项目中,我必须使用基于回调的异步 API。我想介绍一下cats IO
,但我遇到了一些麻烦:
IO.cancelable { cb =>
val subscription = createSubscription(
...,
(msg: Message) => cb { Right("SomeResult") }
)
IO {subscription.unsubscribe()}
}
它看起来很不错,但是我也需要unsubscribe
在收到消息后。不幸IO {subscription.unsubscribe()}
的是,仅在取消的情况下进行评估。我可以快速解决,但这似乎非常违反直觉:
IO.cancelable { cb =>
lazy val subscription = createSubscription(
...,
(msg: Message) => cb {
subscription.unsubscribe() //I can't be really sure if subscription is already initialized
Right("SomeResult")
}
)
subscribe //I have to ensure evalutaion of lazy val
IO {subscription.unsubscribe()}
}
我检查了猫效果文档,遗憾的是我没有找到任何可以帮助我解决这个问题的东西。我可以为这个问题想出一些防弹的解决方案,但它看起来很典型,我不敢相信它还没有解决。
有没有简单的方法来实现这种资源释放行为cats
?