OLD | NEW |
(Empty) | |
| 1 >>> (indent 2) |
| 2 document.onChange.listen(expectAsync((Delta delta) { |
| 3 observedDeltas.add(delta); |
| 4 if (++observedDeltaCount == 3) applyToNewDocument(); |
| 5 }, count: 3)); |
| 6 <<< |
| 7 document.onChange.listen(expectAsync((Delta delta) { |
| 8 observedDeltas.add(delta); |
| 9 if (++observedDeltaCount == 3) applyToNewDocument(); |
| 10 }, count: 3)); |
| 11 >>> (indent 4) |
| 12 return queryWith(fds, otype, whereClause, whereValues).toList() |
| 13 .catchError((ex, st) { |
| 14 _logger.warning( |
| 15 "Failed loadAllWith($fields, $whereClause, $whereValues)", ex, st); |
| 16 return new Future.error(ex, st); |
| 17 }).then((List<Row> rows) { |
| 18 ; |
| 19 }); |
| 20 <<< |
| 21 return queryWith(fds, otype, whereClause, whereValues) |
| 22 .toList() |
| 23 .catchError((ex, st) { |
| 24 _logger.warning( |
| 25 "Failed loadAllWith($fields, $whereClause, $whereValues)", ex, st); |
| 26 return new Future.error(ex, st); |
| 27 }).then((List<Row> rows) { |
| 28 ; |
| 29 }); |
| 30 >>> (indent 4) |
| 31 return _coll.update({"_id": doc["_id"]}, doc, upsert: true) |
| 32 .then((_) => doc); |
| 33 <<< TODO(rnystrom): Should split before .then() but map literal splits chain. |
| 34 return _coll |
| 35 .update({"_id": doc["_id"]}, doc, upsert: true).then((_) => doc); |
OLD | NEW |