1 | "use strict";
|
2 | Object.defineProperty(exports, "__esModule", { value: true });
|
3 | var observables_1 = require("./observables");
|
4 | function subscribeAndCount(done, observable, cb) {
|
5 | var handleCount = 0;
|
6 | var subscription = observables_1.asyncMap(observable, function (result) {
|
7 | try {
|
8 | return cb(++handleCount, result);
|
9 | }
|
10 | catch (e) {
|
11 | setImmediate(function () {
|
12 | subscription.unsubscribe();
|
13 | done.fail(e);
|
14 | });
|
15 | }
|
16 | }).subscribe({
|
17 | error: done.fail,
|
18 | });
|
19 | return subscription;
|
20 | }
|
21 | exports.default = subscribeAndCount;
|
22 |
|
\ | No newline at end of file |