`zip(data.observe(), interval(5, MINUTES).doOnNext...
# rx
j
zip(data.observe(), interval(5, MINUTES).doOnNext { sync() }, (data, _) -> data)