Observable<String> myObservable = Observable.create(
new Observable.OnSubscribe<String😠) {
@Override public void call(Subscriber<? super String> sub) {
String xml = getXmlFromServer();
sub.onNext(xml);
sub.onCompleted();
}
}
).subscribeOn(
Schedulers.io()).observeOn(AndroidThreads.mainThread());
Subscriber<String> mySubscriber = new Subscriber<String😠) {
@Override public void onNext(String s) { System.out.println(s); }
@Override public void onCompleted() { }
@Override public void onError(Throwable e) { }
};
myObservable.subscribe(mySubscriber);