java - 取消订阅不会级联回 RxJava 中的基本可观察值

Question

我有一个可观察对象(示例中的“o”)，我需要在观察者取消订阅后清理某些状态。根据the docs ，取消订阅构建在“o”之上的其他观察者应该级联回“o”。

这种行为似乎仅适用于某些示例。在下面的代码中，我希望“cleanup”消息被打印三次，但在最后一种情况(o1.throttleLast(...))中却没有。

    def o = rx.Observable.create({ subscriber ->
        subscriber.add(Subscriptions.create({ println "cleanup" }))
    })

    o.subscribe({})
        .unsubscribe() // prints

    o.take(1)
        .subscribe({})
        .unsubscribe();  // prints

    o.throttleLast(1, TimeUnit.MILLISECONDS)
        .subscribe({})
        .unsubscribe() // doesn't print

有什么想法吗？谢谢。

Answer 1

RxJava 1.0.3修复了throttleLast的bug。