Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Observable.interval(100, TimeUnit.MILLISECONDS)
- .take(3)
- .timeInterval()
- .subscribe(new Subject<Timed<Long>>() {
- @Override
- public boolean hasObservers() {
- return false;
- }
- @Override
- public boolean hasThrowable() {
- return false;
- }
- @Override
- public boolean hasComplete() {
- return false;
- }
- @Override
- public Throwable getThrowable() {
- return null;
- }
- @Override
- protected void subscribeActual(Observer<? super Timed<Long>> observer) {
- }
- @Override
- public void onSubscribe(Disposable d) {
- }
- @Override
- public void onNext(Timed<Long> longTimed) {
- System.out.println("onNext: " + longTimed);
- }
- @Override
- public void onError(Throwable e) {
- }
- @Override
- public void onComplete() {
- }
- });
- Thread.sleep(3000);
Add Comment
Please, Sign In to add comment