【发布时间】:2017-03-10 21:20:29
【问题描述】:
所以我有一个去抖时间为 300 毫秒的 observable。
它在按键事件后执行 API 调用。
有一个 API 锁可以防止将来调用,直到它完成,但我还想检查 observable 是否正在运行(即进行 API 调用)并停止它。
这将如何实现?
【问题讨论】:
标签: android thread-safety rx-java rx-kotlin
所以我有一个去抖时间为 300 毫秒的 observable。
它在按键事件后执行 API 调用。
有一个 API 锁可以防止将来调用,直到它完成,但我还想检查 observable 是否正在运行(即进行 API 调用)并停止它。
这将如何实现?
【问题讨论】:
标签: android thread-safety rx-java rx-kotlin
不确定是否可以停止 observable,但可以使用 Subscription(或 rx2 中的 Disposable)。完成后,您可以使用它来取消订阅您的 observable。当您调用订阅方法时,订阅会返回。此时保存,然后调用取消订阅,当您不再需要接收事件时
【讨论】: