2 Object.defineProperty(exports, "__esModule", { value: true });
3 var Observable_1 = require("../Observable");
4 var isArray_1 = require("../util/isArray");
5 var isFunction_1 = require("../util/isFunction");
6 var map_1 = require("../operators/map");
7 var toString = (function () { return Object.prototype.toString; })();
8 function fromEvent(target, eventName, options, resultSelector) {
9 if (isFunction_1.isFunction(options)) {
10 resultSelector = options;
14 return fromEvent(target, eventName, options).pipe(map_1.map(function (args) { return isArray_1.isArray(args) ? resultSelector.apply(void 0, args) : resultSelector(args); }));
16 return new Observable_1.Observable(function (subscriber) {
18 if (arguments.length > 1) {
19 subscriber.next(Array.prototype.slice.call(arguments));
25 setupSubscription(target, eventName, handler, subscriber, options);
28 exports.fromEvent = fromEvent;
29 function setupSubscription(sourceObj, eventName, handler, subscriber, options) {
31 if (isEventTarget(sourceObj)) {
32 var source_1 = sourceObj;
33 sourceObj.addEventListener(eventName, handler, options);
34 unsubscribe = function () { return source_1.removeEventListener(eventName, handler, options); };
36 else if (isJQueryStyleEventEmitter(sourceObj)) {
37 var source_2 = sourceObj;
38 sourceObj.on(eventName, handler);
39 unsubscribe = function () { return source_2.off(eventName, handler); };
41 else if (isNodeStyleEventEmitter(sourceObj)) {
42 var source_3 = sourceObj;
43 sourceObj.addListener(eventName, handler);
44 unsubscribe = function () { return source_3.removeListener(eventName, handler); };
46 else if (sourceObj && sourceObj.length) {
47 for (var i = 0, len = sourceObj.length; i < len; i++) {
48 setupSubscription(sourceObj[i], eventName, handler, subscriber, options);
52 throw new TypeError('Invalid event target');
54 subscriber.add(unsubscribe);
56 function isNodeStyleEventEmitter(sourceObj) {
57 return sourceObj && typeof sourceObj.addListener === 'function' && typeof sourceObj.removeListener === 'function';
59 function isJQueryStyleEventEmitter(sourceObj) {
60 return sourceObj && typeof sourceObj.on === 'function' && typeof sourceObj.off === 'function';
62 function isEventTarget(sourceObj) {
63 return sourceObj && typeof sourceObj.addEventListener === 'function' && typeof sourceObj.removeEventListener === 'function';
65 //# sourceMappingURL=fromEvent.js.map