Closed mvberg closed 10 years ago
Obviously this is user error, but we should be protecting against this.
Looks like the issue could be line 154 in DDF_RxInstrumentProvider
Here is a test case
Iterator<Result<Instrument>> res = marketerDDF.getClient().instrument(new String[] { "AAPL", null }).toBlockingObservable().getIterator(); log.warn("res.hasNext() = " + res.hasNext()); // blocks here log.warn("res.next() = " + res.next());
Added a defensive check for this
Obviously this is user error, but we should be protecting against this.
Looks like the issue could be line 154 in DDF_RxInstrumentProvider
Here is a test case