fix buffer return from database query

2015-06-26 01:51:27 -07:00
parent e53419bb59
commit 66e4138b36
1 changed files with 1 additions and 1 deletions
--- a/seed/loopbackMigration.js
+++ b/seed/loopbackMigration.js
@ -165,6 +165,7 @@ var commentCount = dbObservable
  .flatMap(function(db) {
    return createQuery(db, 'comments', {});
  })
+  .bufferWithCount(20)
  .withLatestFrom(dbObservable, function(comments, db) {
    return {
      comments: comments,
@ -174,7 +175,6 @@ var commentCount = dbObservable
  .flatMap(function(dats) {
    return insertMany(dats.db, 'comment', dats.comments, { w: 1 });
  })
-  .bufferWithCount(20)
  .count();

 Rx.Observable.combineLatest(