if (selector) {
                            try {
                                results = selector(results);
                            } catch (e) {
                                observer.onError(e);