source: trip-planner-front/node_modules/rxjs/_esm5/internal/observable/fromEvent.js

Last change on this file was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 2.7 KB
Line 
1/** PURE_IMPORTS_START _Observable,_util_isArray,_util_isFunction,_operators_map PURE_IMPORTS_END */
2import { Observable } from '../Observable';
3import { isArray } from '../util/isArray';
4import { isFunction } from '../util/isFunction';
5import { map } from '../operators/map';
6var toString = /*@__PURE__*/ (function () { return Object.prototype.toString; })();
7export function fromEvent(target, eventName, options, resultSelector) {
8 if (isFunction(options)) {
9 resultSelector = options;
10 options = undefined;
11 }
12 if (resultSelector) {
13 return fromEvent(target, eventName, options).pipe(map(function (args) { return isArray(args) ? resultSelector.apply(void 0, args) : resultSelector(args); }));
14 }
15 return new Observable(function (subscriber) {
16 function handler(e) {
17 if (arguments.length > 1) {
18 subscriber.next(Array.prototype.slice.call(arguments));
19 }
20 else {
21 subscriber.next(e);
22 }
23 }
24 setupSubscription(target, eventName, handler, subscriber, options);
25 });
26}
27function setupSubscription(sourceObj, eventName, handler, subscriber, options) {
28 var unsubscribe;
29 if (isEventTarget(sourceObj)) {
30 var source_1 = sourceObj;
31 sourceObj.addEventListener(eventName, handler, options);
32 unsubscribe = function () { return source_1.removeEventListener(eventName, handler, options); };
33 }
34 else if (isJQueryStyleEventEmitter(sourceObj)) {
35 var source_2 = sourceObj;
36 sourceObj.on(eventName, handler);
37 unsubscribe = function () { return source_2.off(eventName, handler); };
38 }
39 else if (isNodeStyleEventEmitter(sourceObj)) {
40 var source_3 = sourceObj;
41 sourceObj.addListener(eventName, handler);
42 unsubscribe = function () { return source_3.removeListener(eventName, handler); };
43 }
44 else if (sourceObj && sourceObj.length) {
45 for (var i = 0, len = sourceObj.length; i < len; i++) {
46 setupSubscription(sourceObj[i], eventName, handler, subscriber, options);
47 }
48 }
49 else {
50 throw new TypeError('Invalid event target');
51 }
52 subscriber.add(unsubscribe);
53}
54function isNodeStyleEventEmitter(sourceObj) {
55 return sourceObj && typeof sourceObj.addListener === 'function' && typeof sourceObj.removeListener === 'function';
56}
57function isJQueryStyleEventEmitter(sourceObj) {
58 return sourceObj && typeof sourceObj.on === 'function' && typeof sourceObj.off === 'function';
59}
60function isEventTarget(sourceObj) {
61 return sourceObj && typeof sourceObj.addEventListener === 'function' && typeof sourceObj.removeEventListener === 'function';
62}
63//# sourceMappingURL=fromEvent.js.map
Note: See TracBrowser for help on using the repository browser.