Closed mvberg closed 10 years ago
maybe this is by design, since I am doing toBlockingObservable - testing now with non blocking - will reopen if still an issue
Nope, still happens when using subscribe, onError only fires
final String[] instruments = new String[] { "GOOG", "MSFT", "YHOO", "BADBADSYMBOL" };
view.getMarketer().feed().instrument(instruments).subscribe(new Observer<Result<Instrument>>() {
@Override
public void onCompleted() {
// TODO Auto-generated method stub
}
@Override
public void onError(Throwable e) {
System.out.println("list look up error, e = " + e);
}
@Override
public void onNext(Result<Instrument> args) {
System.out.println("on next = " + args.results().size());
}
});
You need an intervening observable with a Func that handles "onError", then call toBlocking... on that maybe?? Hmmm...
Sent from my iPhone
On Feb 19, 2014, at 4:17 PM, Mike Ehrenberg notifications@github.com wrote:
Reopened #4.
— Reply to this email directly or view it on GitHub.
Looking into it now
fixed up, thanks.
Throws this uncatchable exception
Full trace: https://gist.github.com/mvberg/9102684
Run this to repo