import rx.Observable;
import rx.Subscriber;
public class MyLibrary {
public Observable<String> fetchData() {
return Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
try {
Thread.sleep(1000);
subscriber.onNext("Hello, RxJS!");
subscriber.onCompleted();
} catch (Exception e) {
subscriber.onError(e);
}
}
});
}
public static void main(String[] args) {
MyLibrary myLibrary = new MyLibrary();
myLibrary.fetchData().subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
});
}
}
