我只是最近才开始使用Rx,因此,如果这不是执行我要执行的操作的最佳方法,请更正它。
目标:拥有一个可观察到的命中API(具有Retrofit),并且每次执行都会将响应保存到本地存储,但是不必每次订阅时都做,因为我会在多个地方进行操作。
有这样的事情:
myRetrofit.create(MyInterface::class.java).hitEndpoint()
我想做这样的事情:
myRetrofit.create(MyInterface::class.java).hitEndpoint()
.intercept { storageUtils.saveItem("key", it) }
问题:如何在观察对象订阅之前运行函数?
根据@akarnokd的评论,我只是使用.doOnNext { }
。
其他解决方案也可以使用,但这是最简单的。
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句