Details
-
Bug
-
Resolution: Fixed
-
Major
-
None
-
None
-
Security Level: Public
-
None
Description
Here is the code I used. This doesn't call onError.
ViewQuery queryTemplate = ViewQuery.from("test","dummy");
queryTemplate.stale(Stale.FALSE);
Observable<ViewRow> viewRowObservable = bucket.query(queryTemplate).flatMap(new Func1<ViewResult, Observable<ViewRow>>() {
public Observable<ViewRow> call(ViewResult res)
});
viewRowObservable.subscribe(new Observer<ViewRow>() {
@Override
public void onCompleted()
@Override
public void onError(Throwable throwable)
@Override
public void onNext(ViewRow viewRow) {
}
});