1 import { Observable } from '../Observable';
2 import { isArray } from '../util/isArray';
3 import { isFunction } from '../util/isFunction';
4 import { map } from '../operators/map';
5 export function fromEventPattern(addHandler, removeHandler, resultSelector) {
7 return fromEventPattern(addHandler, removeHandler).pipe(map(args => isArray(args) ? resultSelector(...args) : resultSelector(args)));
9 return new Observable(subscriber => {
10 const handler = (...e) => subscriber.next(e.length === 1 ? e[0] : e);
13 retValue = addHandler(handler);
16 subscriber.error(err);
19 if (!isFunction(removeHandler)) {
22 return () => removeHandler(handler, retValue);
25 //# sourceMappingURL=fromEventPattern.js.map