65 lines
2.7 KiB
JavaScript
65 lines
2.7 KiB
JavaScript
"use strict";
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
var Observable_1 = require("../Observable");
|
|
var isArray_1 = require("../util/isArray");
|
|
var isFunction_1 = require("../util/isFunction");
|
|
var map_1 = require("../operators/map");
|
|
var toString = (function () { return Object.prototype.toString; })();
|
|
function fromEvent(target, eventName, options, resultSelector) {
|
|
if (isFunction_1.isFunction(options)) {
|
|
resultSelector = options;
|
|
options = undefined;
|
|
}
|
|
if (resultSelector) {
|
|
return fromEvent(target, eventName, options).pipe(map_1.map(function (args) { return isArray_1.isArray(args) ? resultSelector.apply(void 0, args) : resultSelector(args); }));
|
|
}
|
|
return new Observable_1.Observable(function (subscriber) {
|
|
function handler(e) {
|
|
if (arguments.length > 1) {
|
|
subscriber.next(Array.prototype.slice.call(arguments));
|
|
}
|
|
else {
|
|
subscriber.next(e);
|
|
}
|
|
}
|
|
setupSubscription(target, eventName, handler, subscriber, options);
|
|
});
|
|
}
|
|
exports.fromEvent = fromEvent;
|
|
function setupSubscription(sourceObj, eventName, handler, subscriber, options) {
|
|
var unsubscribe;
|
|
if (isEventTarget(sourceObj)) {
|
|
var source_1 = sourceObj;
|
|
sourceObj.addEventListener(eventName, handler, options);
|
|
unsubscribe = function () { return source_1.removeEventListener(eventName, handler, options); };
|
|
}
|
|
else if (isJQueryStyleEventEmitter(sourceObj)) {
|
|
var source_2 = sourceObj;
|
|
sourceObj.on(eventName, handler);
|
|
unsubscribe = function () { return source_2.off(eventName, handler); };
|
|
}
|
|
else if (isNodeStyleEventEmitter(sourceObj)) {
|
|
var source_3 = sourceObj;
|
|
sourceObj.addListener(eventName, handler);
|
|
unsubscribe = function () { return source_3.removeListener(eventName, handler); };
|
|
}
|
|
else if (sourceObj && sourceObj.length) {
|
|
for (var i = 0, len = sourceObj.length; i < len; i++) {
|
|
setupSubscription(sourceObj[i], eventName, handler, subscriber, options);
|
|
}
|
|
}
|
|
else {
|
|
throw new TypeError('Invalid event target');
|
|
}
|
|
subscriber.add(unsubscribe);
|
|
}
|
|
function isNodeStyleEventEmitter(sourceObj) {
|
|
return sourceObj && typeof sourceObj.addListener === 'function' && typeof sourceObj.removeListener === 'function';
|
|
}
|
|
function isJQueryStyleEventEmitter(sourceObj) {
|
|
return sourceObj && typeof sourceObj.on === 'function' && typeof sourceObj.off === 'function';
|
|
}
|
|
function isEventTarget(sourceObj) {
|
|
return sourceObj && typeof sourceObj.addEventListener === 'function' && typeof sourceObj.removeEventListener === 'function';
|
|
}
|
|
//# sourceMappingURL=fromEvent.js.map
|