diff --git a/seed/loopbackMigration.js b/seed/loopbackMigration.js index 1a86352e46..31a0ef5545 100644 --- a/seed/loopbackMigration.js +++ b/seed/loopbackMigration.js @@ -7,6 +7,7 @@ var Rx = require('rx'), secrets = require('../config/secrets'); var MongoClient = mongodb.MongoClient; +Rx.config.longStackSupport = true; var providers = [ 'facebook', @@ -173,7 +174,7 @@ var commentCount = dbObservable .flatMap(function(dats) { return insertMany(dats.db, 'comment', dats.comments, { w: 1 }); }) - .buffer(20) + .bufferWithCount(20) .count(); Rx.Observable.combineLatest( @@ -198,7 +199,6 @@ Rx.Observable.combineLatest( console.error('an error occured', err, err.stack); }, function() { - console.log('finished with ', count); process.exit(0); }