Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
function Aggregate(collection, options) {
if (!(this instanceof Aggregate)) return new Aggregate(collection, options)
// readable mode for streaming the cursor
Readable.call(this, {
objectMode: true
})
this.collection = collection
this.options = options = options || {}
this.pipeline = []
}
function InputStream(source, options) {
if (!(this instanceof InputStream))
return new InputStream(source, options);
Readable.call(this, options);
options = options || { highWaterMark: 16 * 1024 };
// source is a winrt iinputstream, such as a socket or file
this._source = source;
this._buffer = new Buffer(options.highWaterMark);
}
function Query(collection, options) {
if (!(this instanceof Query)) return new Query(collection, options)
Readable.call(this, {
objectMode: true
})
this.collection = collection
this.criteria = {}
this.document = {}
this.options = options || {}
// which type of .then() is set
this._then = 'query'
}
function ReadStream() {
Readable.call(this);
this._offset = 0;
this.readable = false;
this.complete = false;
this._object = new Buffer(0);
}
function Stream (element, host) {
this.host = host
this.stack = [element]
Readable.call(this)
}
/**