Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
package com.codingsaint.learning.rxjava.observables;
import com.codingsaint.learning.rxjava.observer.DemoObserver;
import com.codingsaint.learning.rxjava.utils.RxUtils;
import io.reactivex.Observable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.concurrent.TimeUnit;
public class ObservableUsingTimer {
private static final Logger LOGGER = LoggerFactory.getLogger(ObservableUsingTimer.class);
public static void main(String... args) {
Observable.timer(5, TimeUnit.SECONDS)
.subscribe(new DemoObserver());
RxUtils.sleep(7000);
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment