that said, your example code is better written as ...

# android

[jw]

that said, your example code is better written as timer(1, SECONDS).concatWith(interval(1, SECONDS)) or interval(1, SECONDS).delaySubscription(1, SECONDS)