fix should be bufferWithCount

This commit is contained in:
Berkeley Martinez
2015-06-26 01:47:59 -07:00
parent 3bac247627
commit e53419bb59

View File

@ -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);
}