import io.reactivex.rxjava3.core.Observable;

import io.reactivex.rxjava3.disposables.Disposable;

import io.reactivex.rxjava3.observers.ResourceObserver;

import java.util.concurrent.TimeUnit;

public class Ch2_34 {

public static void main(String[] args) {

Observable<Long> source =

Observable.interval(1, TimeUnit.SECONDS);

ResourceObserver<Long> myObserver = new

ResourceObserver<Long>() {

@Override

public void onNext(Long value) {

System.out.println(value);

}

@Override

public void onError(Throwable e) {

e.printStackTrace();

}

@Override

public void onComplete() {

System.out.println("Done!");

}

};

//capture Disposable

Disposable disposable = source.subscribeWith(myObserver);

}

}