1 /** PURE_IMPORTS_START _Observable,_AsyncSubject,_operators_map,_util_canReportError,_util_isArray,_util_isScheduler PURE_IMPORTS_END */
2 import { Observable } from '../Observable';
3 import { AsyncSubject } from '../AsyncSubject';
4 import { map } from '../operators/map';
5 import { canReportError } from '../util/canReportError';
6 import { isArray } from '../util/isArray';
7 import { isScheduler } from '../util/isScheduler';
8 export function bindCallback(callbackFunc, resultSelector, scheduler) {
10 if (isScheduler(resultSelector)) {
11 scheduler = resultSelector;
16 for (var _i = 0; _i < arguments.length; _i++) {
17 args[_i] = arguments[_i];
19 return bindCallback(callbackFunc, scheduler).apply(void 0, args).pipe(map(function (args) { return isArray(args) ? resultSelector.apply(void 0, args) : resultSelector(args); }));
25 for (var _i = 0; _i < arguments.length; _i++) {
26 args[_i] = arguments[_i];
33 callbackFunc: callbackFunc,
36 return new Observable(function (subscriber) {
39 subject = new AsyncSubject();
40 var handler = function () {
42 for (var _i = 0; _i < arguments.length; _i++) {
43 innerArgs[_i] = arguments[_i];
45 subject.next(innerArgs.length <= 1 ? innerArgs[0] : innerArgs);
49 callbackFunc.apply(context, args.concat([handler]));
52 if (canReportError(subject)) {
60 return subject.subscribe(subscriber);
64 args: args, subscriber: subscriber, params: params,
66 return scheduler.schedule(dispatch, 0, state);
71 function dispatch(state) {
74 var args = state.args, subscriber = state.subscriber, params = state.params;
75 var callbackFunc = params.callbackFunc, context = params.context, scheduler = params.scheduler;
76 var subject = params.subject;
78 subject = params.subject = new AsyncSubject();
79 var handler = function () {
81 for (var _i = 0; _i < arguments.length; _i++) {
82 innerArgs[_i] = arguments[_i];
84 var value = innerArgs.length <= 1 ? innerArgs[0] : innerArgs;
85 _this.add(scheduler.schedule(dispatchNext, 0, { value: value, subject: subject }));
88 callbackFunc.apply(context, args.concat([handler]));
94 this.add(subject.subscribe(subscriber));
96 function dispatchNext(state) {
97 var value = state.value, subject = state.subject;
101 function dispatchError(state) {
102 var err = state.err, subject = state.subject;
105 //# sourceMappingURL=bindCallback.js.map