2 Object.defineProperty(exports, "__esModule", { value: true });
3 var Observable_1 = require("../Observable");
4 var AsyncSubject_1 = require("../AsyncSubject");
5 var map_1 = require("../operators/map");
6 var canReportError_1 = require("../util/canReportError");
7 var isArray_1 = require("../util/isArray");
8 var isScheduler_1 = require("../util/isScheduler");
9 function bindCallback(callbackFunc, resultSelector, scheduler) {
11 if (isScheduler_1.isScheduler(resultSelector)) {
12 scheduler = resultSelector;
17 for (var _i = 0; _i < arguments.length; _i++) {
18 args[_i] = arguments[_i];
20 return bindCallback(callbackFunc, scheduler).apply(void 0, args).pipe(map_1.map(function (args) { return isArray_1.isArray(args) ? resultSelector.apply(void 0, args) : resultSelector(args); }));
26 for (var _i = 0; _i < arguments.length; _i++) {
27 args[_i] = arguments[_i];
34 callbackFunc: callbackFunc,
37 return new Observable_1.Observable(function (subscriber) {
40 subject = new AsyncSubject_1.AsyncSubject();
41 var handler = function () {
43 for (var _i = 0; _i < arguments.length; _i++) {
44 innerArgs[_i] = arguments[_i];
46 subject.next(innerArgs.length <= 1 ? innerArgs[0] : innerArgs);
50 callbackFunc.apply(context, args.concat([handler]));
53 if (canReportError_1.canReportError(subject)) {
61 return subject.subscribe(subscriber);
65 args: args, subscriber: subscriber, params: params,
67 return scheduler.schedule(dispatch, 0, state);
72 exports.bindCallback = bindCallback;
73 function dispatch(state) {
76 var args = state.args, subscriber = state.subscriber, params = state.params;
77 var callbackFunc = params.callbackFunc, context = params.context, scheduler = params.scheduler;
78 var subject = params.subject;
80 subject = params.subject = new AsyncSubject_1.AsyncSubject();
81 var handler = function () {
83 for (var _i = 0; _i < arguments.length; _i++) {
84 innerArgs[_i] = arguments[_i];
86 var value = innerArgs.length <= 1 ? innerArgs[0] : innerArgs;
87 _this.add(scheduler.schedule(dispatchNext, 0, { value: value, subject: subject }));
90 callbackFunc.apply(context, args.concat([handler]));
96 this.add(subject.subscribe(subscriber));
98 function dispatchNext(state) {
99 var value = state.value, subject = state.subject;
103 function dispatchError(state) {
104 var err = state.err, subject = state.subject;
107 //# sourceMappingURL=bindCallback.js.map