schedulePeriodically cannot be unsubscribed from

[samueltardieu]

The subscription returned by schedulePeriodically() is automatically marked as unsubscribed when the first run terminates, after queuing the next event. As a result, the periodic event cannot be unsubscribed from once the first call() happens, as unsubscribe() will now be a no-op (as isUnsubscribed is true).

Example in the Scala REPL (with the Java bindings for RxJava 0.19):

import rx._
import rx.functions._
import rx.schedulers.Schedulers
import java.util.concurrent.TimeUnit
val s = Schedulers.io().createWorker.schedulePeriodically(new Action0 { override def call = println("In call") }, 1, 1, TimeUnit.SECONDS)
s.isUnsubscribed

Here, s.isUnsubscribed() returns false. However, if you wait one second, it will return true and s.unsubscribe() will not do anything and the constant display will continue every second.