+++ /dev/null
-import { Observable } from '../Observable';
-import { isArray } from '../util/isArray';
-import { isFunction } from '../util/isFunction';
-import { map } from '../operators/map';
-const toString = (() => Object.prototype.toString)();
-export function fromEvent(target, eventName, options, resultSelector) {
- if (isFunction(options)) {
- resultSelector = options;
- options = undefined;
- }
- if (resultSelector) {
- return fromEvent(target, eventName, options).pipe(map(args => isArray(args) ? resultSelector(...args) : resultSelector(args)));
- }
- return new Observable(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);
- });
-}
-function setupSubscription(sourceObj, eventName, handler, subscriber, options) {
- let unsubscribe;
- if (isEventTarget(sourceObj)) {
- const source = sourceObj;
- sourceObj.addEventListener(eventName, handler, options);
- unsubscribe = () => source.removeEventListener(eventName, handler, options);
- }
- else if (isJQueryStyleEventEmitter(sourceObj)) {
- const source = sourceObj;
- sourceObj.on(eventName, handler);
- unsubscribe = () => source.off(eventName, handler);
- }
- else if (isNodeStyleEventEmitter(sourceObj)) {
- const source = sourceObj;
- sourceObj.addListener(eventName, handler);
- unsubscribe = () => source.removeListener(eventName, handler);
- }
- else if (sourceObj && sourceObj.length) {
- for (let 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
\ No newline at end of file