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 isScheduler_1 = require("../util/isScheduler");
8 var isArray_1 = require("../util/isArray");
9 function bindNodeCallback(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 bindNodeCallback(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];
32 callbackFunc: callbackFunc,
36 return new Observable_1.Observable(function (subscriber) {
37 var context = params.context;
38 var subject = params.subject;
41 subject = params.subject = new AsyncSubject_1.AsyncSubject();
42 var handler = function () {
44 for (var _i = 0; _i < arguments.length; _i++) {
45 innerArgs[_i] = arguments[_i];
47 var err = innerArgs.shift();
52 subject.next(innerArgs.length <= 1 ? innerArgs[0] : innerArgs);
56 callbackFunc.apply(context, args.concat([handler]));
59 if (canReportError_1.canReportError(subject)) {
67 return subject.subscribe(subscriber);
70 return scheduler.schedule(dispatch, 0, { params: params, subscriber: subscriber, context: context });
75 exports.bindNodeCallback = bindNodeCallback;
76 function dispatch(state) {
78 var params = state.params, subscriber = state.subscriber, context = state.context;
79 var callbackFunc = params.callbackFunc, args = params.args, scheduler = params.scheduler;
80 var subject = params.subject;
82 subject = params.subject = new AsyncSubject_1.AsyncSubject();
83 var handler = function () {
85 for (var _i = 0; _i < arguments.length; _i++) {
86 innerArgs[_i] = arguments[_i];
88 var err = innerArgs.shift();
90 _this.add(scheduler.schedule(dispatchError, 0, { err: err, subject: subject }));
93 var value = innerArgs.length <= 1 ? innerArgs[0] : innerArgs;
94 _this.add(scheduler.schedule(dispatchNext, 0, { value: value, subject: subject }));
98 callbackFunc.apply(context, args.concat([handler]));
101 this.add(scheduler.schedule(dispatchError, 0, { err: err, subject: subject }));
104 this.add(subject.subscribe(subscriber));
106 function dispatchNext(arg) {
107 var value = arg.value, subject = arg.subject;
111 function dispatchError(arg) {
112 var err = arg.err, subject = arg.subject;
115 //# sourceMappingURL=bindNodeCallback.js.map