@@ -13253,19 +13253,55 @@ var ParseQuery = /*#__PURE__*/function () {
13253
13253
var previousResults = [];
13254
13254
return (0, _promiseUtils.continueWhile)(function () {
13255
13255
return !finished;
13256
- }, function () {
13257
- return _promise.default.all([(0, _find.default)(query).call(query, findOptions), _promise.default.resolve(callback(previousResults))]).then(function (_ref) {
13258
- var _ref2 = (0, _slicedToArray2.default)(_ref, 1),
13259
- results = _ref2[0];
13256
+ }, /*#__PURE__*/(0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee2() {
13257
+ var _yield$Promise$all, _yield$Promise$all2, results;
13260
13258
13261
- if (results.length == 0) {
13262
- finished = true;
13263
- } else {
13264
- query.greaterThan('objectId', results[results.length - 1].id);
13265
- previousResults = results;
13259
+ return _regenerator.default.wrap(function (_context8) {
13260
+ while (1) {
13261
+ switch (_context8.prev = _context8.next) {
13262
+ case 0:
13263
+ _context8.next = 2;
13264
+ return _promise.default.all([(0, _find.default)(query).call(query, findOptions), _promise.default.resolve(callback(previousResults))]);
13265
+
13266
+ case 2:
13267
+ _yield$Promise$all = _context8.sent;
13268
+ _yield$Promise$all2 = (0, _slicedToArray2.default)(_yield$Promise$all, 1);
13269
+ results = _yield$Promise$all2[0];
13270
+
13271
+ if (!(results.length >= query._limit)) {
13272
+ _context8.next = 10;
13273
+ break;
13274
+ }
13275
+
13276
+ query.greaterThan('objectId', results[results.length - 1].id);
13277
+ previousResults = results;
13278
+ _context8.next = 17;
13279
+ break;
13280
+
13281
+ case 10:
13282
+ if (!(results.length > 0)) {
13283
+ _context8.next = 16;
13284
+ break;
13285
+ }
13286
+
13287
+ _context8.next = 13;
13288
+ return _promise.default.resolve(callback(results));
13289
+
13290
+ case 13:
13291
+ finished = true;
13292
+ _context8.next = 17;
13293
+ break;
13294
+
13295
+ case 16:
13296
+ finished = true;
13297
+
13298
+ case 17:
13299
+ case "end":
13300
+ return _context8.stop();
13301
+ }
13266
13302
}
13267
- });
13268
- });
13303
+ }, _callee2 );
13304
+ }))) ;
13269
13305
}
13270
13306
/**
13271
13307
* Iterates over each result of a query, calling a callback for each one. If
@@ -13376,21 +13412,21 @@ var ParseQuery = /*#__PURE__*/function () {
13376
13412
}, {
13377
13413
key: "map",
13378
13414
value: function () {
13379
- var _map = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee2 (callback
13415
+ var _map = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee3 (callback
13380
13416
/*: (currentObject: ParseObject, index: number, query: ParseQuery) => any*/
13381
13417
, options
13382
13418
/*:: ?: BatchOptions*/
13383
13419
) {
13384
13420
var _this5 = this;
13385
13421
13386
13422
var array, index;
13387
- return _regenerator.default.wrap(function (_context8 ) {
13423
+ return _regenerator.default.wrap(function (_context9 ) {
13388
13424
while (1) {
13389
- switch (_context8 .prev = _context8 .next) {
13425
+ switch (_context9 .prev = _context9 .next) {
13390
13426
case 0:
13391
13427
array = [];
13392
13428
index = 0;
13393
- _context8 .next = 4;
13429
+ _context9 .next = 4;
13394
13430
return this.each(function (object) {
13395
13431
return _promise.default.resolve(callback(object, index, _this5)).then(function (result) {
13396
13432
array.push(result);
@@ -13399,14 +13435,14 @@ var ParseQuery = /*#__PURE__*/function () {
13399
13435
}, options);
13400
13436
13401
13437
case 4:
13402
- return _context8 .abrupt("return", array);
13438
+ return _context9 .abrupt("return", array);
13403
13439
13404
13440
case 5:
13405
13441
case "end":
13406
- return _context8 .stop();
13442
+ return _context9 .stop();
13407
13443
}
13408
13444
}
13409
- }, _callee2 , this);
13445
+ }, _callee3 , this);
13410
13446
}));
13411
13447
13412
13448
return function () {
@@ -13439,21 +13475,21 @@ var ParseQuery = /*#__PURE__*/function () {
13439
13475
}, {
13440
13476
key: "reduce",
13441
13477
value: function () {
13442
- var _reduce = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee3 (callback
13478
+ var _reduce = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee4 (callback
13443
13479
/*: (accumulator: any, currentObject: ParseObject, index: number) => any*/
13444
13480
, initialValue
13445
13481
/*: any*/
13446
13482
, options
13447
13483
/*:: ?: BatchOptions*/
13448
13484
) {
13449
13485
var accumulator, index;
13450
- return _regenerator.default.wrap(function (_context9 ) {
13486
+ return _regenerator.default.wrap(function (_context10 ) {
13451
13487
while (1) {
13452
- switch (_context9 .prev = _context9 .next) {
13488
+ switch (_context10 .prev = _context10 .next) {
13453
13489
case 0:
13454
13490
accumulator = initialValue;
13455
13491
index = 0;
13456
- _context9 .next = 4;
13492
+ _context10 .next = 4;
13457
13493
return this.each(function (object) {
13458
13494
// If no initial value was given, we take the first object from the query
13459
13495
// as the initial value and don't call the callback with it.
@@ -13471,21 +13507,21 @@ var ParseQuery = /*#__PURE__*/function () {
13471
13507
13472
13508
case 4:
13473
13509
if (!(index === 0 && initialValue === undefined)) {
13474
- _context9 .next = 6;
13510
+ _context10 .next = 6;
13475
13511
break;
13476
13512
}
13477
13513
13478
13514
throw new TypeError("Reducing empty query result set with no initial value");
13479
13515
13480
13516
case 6:
13481
- return _context9 .abrupt("return", accumulator);
13517
+ return _context10 .abrupt("return", accumulator);
13482
13518
13483
13519
case 7:
13484
13520
case "end":
13485
- return _context9 .stop();
13521
+ return _context10 .stop();
13486
13522
}
13487
13523
}
13488
- }, _callee3 , this);
13524
+ }, _callee4 , this);
13489
13525
}));
13490
13526
13491
13527
return function () {
@@ -13518,21 +13554,21 @@ var ParseQuery = /*#__PURE__*/function () {
13518
13554
}, {
13519
13555
key: "filter",
13520
13556
value: function () {
13521
- var _filter = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee4 (callback
13557
+ var _filter = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee5 (callback
13522
13558
/*: (currentObject: ParseObject, index: number, query: ParseQuery) => boolean*/
13523
13559
, options
13524
13560
/*:: ?: BatchOptions*/
13525
13561
) {
13526
13562
var _this6 = this;
13527
13563
13528
13564
var array, index;
13529
- return _regenerator.default.wrap(function (_context10 ) {
13565
+ return _regenerator.default.wrap(function (_context11 ) {
13530
13566
while (1) {
13531
- switch (_context10 .prev = _context10 .next) {
13567
+ switch (_context11 .prev = _context11 .next) {
13532
13568
case 0:
13533
13569
array = [];
13534
13570
index = 0;
13535
- _context10 .next = 4;
13571
+ _context11 .next = 4;
13536
13572
return this.each(function (object) {
13537
13573
return _promise.default.resolve(callback(object, index, _this6)).then(function (flag) {
13538
13574
if (flag) {
@@ -13544,14 +13580,14 @@ var ParseQuery = /*#__PURE__*/function () {
13544
13580
}, options);
13545
13581
13546
13582
case 4:
13547
- return _context10 .abrupt("return", array);
13583
+ return _context11 .abrupt("return", array);
13548
13584
13549
13585
case 5:
13550
13586
case "end":
13551
- return _context10 .stop();
13587
+ return _context11 .stop();
13552
13588
}
13553
13589
}
13554
- }, _callee4 , this);
13590
+ }, _callee5 , this);
13555
13591
}));
13556
13592
13557
13593
return function () {
@@ -14370,13 +14406,13 @@ var ParseQuery = /*#__PURE__*/function () {
14370
14406
}
14371
14407
14372
14408
(0, _forEach.default)(keys).call(keys, function (key) {
14373
- var _context11 ;
14409
+ var _context12 ;
14374
14410
14375
14411
if ((0, _isArray.default)(key)) {
14376
14412
key = key.join();
14377
14413
}
14378
14414
14379
- _this7._order = (0, _concat.default)(_context11 = _this7._order).call(_context11 , key.replace(/\s/g, '').split(','));
14415
+ _this7._order = (0, _concat.default)(_context12 = _this7._order).call(_context12 , key.replace(/\s/g, '').split(','));
14380
14416
});
14381
14417
return this;
14382
14418
}
@@ -14426,13 +14462,13 @@ var ParseQuery = /*#__PURE__*/function () {
14426
14462
}
14427
14463
14428
14464
(0, _forEach.default)(keys).call(keys, function (key) {
14429
- var _context12, _context13 ;
14465
+ var _context13, _context14 ;
14430
14466
14431
14467
if ((0, _isArray.default)(key)) {
14432
14468
key = key.join();
14433
14469
}
14434
14470
14435
- _this8._order = (0, _concat.default)(_context12 = _this8._order).call(_context12 , (0, _map2.default)(_context13 = key.replace(/\s/g, '').split(',')).call(_context13 , function (k) {
14471
+ _this8._order = (0, _concat.default)(_context13 = _this8._order).call(_context13 , (0, _map2.default)(_context14 = key.replace(/\s/g, '').split(',')).call(_context14 , function (k) {
14436
14472
return '-' + k;
14437
14473
}));
14438
14474
});
@@ -14533,9 +14569,9 @@ var ParseQuery = /*#__PURE__*/function () {
14533
14569
14534
14570
(0, _forEach.default)(keys).call(keys, function (key) {
14535
14571
if ((0, _isArray.default)(key)) {
14536
- var _context14 ;
14572
+ var _context15 ;
14537
14573
14538
- _this9._include = (0, _concat.default)(_context14 = _this9._include).call(_context14 , key);
14574
+ _this9._include = (0, _concat.default)(_context15 = _this9._include).call(_context15 , key);
14539
14575
} else {
14540
14576
_this9._include.push(key);
14541
14577
}
@@ -14582,9 +14618,9 @@ var ParseQuery = /*#__PURE__*/function () {
14582
14618
14583
14619
(0, _forEach.default)(keys).call(keys, function (key) {
14584
14620
if ((0, _isArray.default)(key)) {
14585
- var _context15 ;
14621
+ var _context16 ;
14586
14622
14587
- _this10._select = (0, _concat.default)(_context15 = _this10._select).call(_context15 , key);
14623
+ _this10._select = (0, _concat.default)(_context16 = _this10._select).call(_context16 , key);
14588
14624
} else {
14589
14625
_this10._select.push(key);
14590
14626
}
@@ -14614,9 +14650,9 @@ var ParseQuery = /*#__PURE__*/function () {
14614
14650
14615
14651
(0, _forEach.default)(keys).call(keys, function (key) {
14616
14652
if ((0, _isArray.default)(key)) {
14617
- var _context16 ;
14653
+ var _context17 ;
14618
14654
14619
- _this11._exclude = (0, _concat.default)(_context16 = _this11._exclude).call(_context16 , key);
14655
+ _this11._exclude = (0, _concat.default)(_context17 = _this11._exclude).call(_context17 , key);
14620
14656
} else {
14621
14657
_this11._exclude.push(key);
14622
14658
}
@@ -14658,45 +14694,45 @@ var ParseQuery = /*#__PURE__*/function () {
14658
14694
}, {
14659
14695
key: "subscribe",
14660
14696
value: function () {
14661
- var _subscribe = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee5 (sessionToken
14697
+ var _subscribe = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee6 (sessionToken
14662
14698
/*:: ?: string*/
14663
14699
) {
14664
14700
var currentUser, liveQueryClient, subscription;
14665
- return _regenerator.default.wrap(function (_context17 ) {
14701
+ return _regenerator.default.wrap(function (_context18 ) {
14666
14702
while (1) {
14667
- switch (_context17 .prev = _context17 .next) {
14703
+ switch (_context18 .prev = _context18 .next) {
14668
14704
case 0:
14669
- _context17 .next = 2;
14705
+ _context18 .next = 2;
14670
14706
return _CoreManager.default.getUserController().currentUserAsync();
14671
14707
14672
14708
case 2:
14673
- currentUser = _context17 .sent;
14709
+ currentUser = _context18 .sent;
14674
14710
14675
14711
if (!sessionToken) {
14676
14712
sessionToken = currentUser ? currentUser.getSessionToken() : undefined;
14677
14713
}
14678
14714
14679
- _context17 .next = 6;
14715
+ _context18 .next = 6;
14680
14716
return _CoreManager.default.getLiveQueryController().getDefaultLiveQueryClient();
14681
14717
14682
14718
case 6:
14683
- liveQueryClient = _context17 .sent;
14719
+ liveQueryClient = _context18 .sent;
14684
14720
14685
14721
if (liveQueryClient.shouldOpen()) {
14686
14722
liveQueryClient.open();
14687
14723
}
14688
14724
14689
14725
subscription = liveQueryClient.subscribe(this, sessionToken);
14690
- return _context17 .abrupt("return", subscription.subscribePromise.then(function () {
14726
+ return _context18 .abrupt("return", subscription.subscribePromise.then(function () {
14691
14727
return subscription;
14692
14728
}));
14693
14729
14694
14730
case 10:
14695
14731
case "end":
14696
- return _context17 .stop();
14732
+ return _context18 .stop();
14697
14733
}
14698
14734
}
14699
- }, _callee5 , this);
14735
+ }, _callee6 , this);
14700
14736
}));
14701
14737
14702
14738
return function () {
0 commit comments