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