Class: MongooseStream

@e2fyi/streams.MongooseStream(opts)

A custom NodeJS Transform stream to mongo via mongoose.

Constructor

new MongooseStream(opts)

Create a Transform stream which bulkWrite to mongo based on the itemWaterMark. model (mongoose Model) is a required field.

Parameters:
Name Type Description
opts MongooseStreamSettings

Configuration for MongoStream. Default value for itemWaterMark is 50.
Source:
Fires:
Example
var stream2mongo = new MongooseStream({mode: SomeMongooseModel});
someReadableStreamFromArray([{text: 'abc'}, {text: 'efg'}])
  .pipe(stream2mongo) // writes to mongo (while stream are also passthrough)
  .pipe(response); // stream same results back to some request

Extends

  • stream.Transform