return $mongo.db.then(db => {
  //db is a singleton Mongo Db instance
});

const Qwebs = require("qwebs");
const qwebs = new Qwebs();
qwebs.inject("$mongo" ,"qwebs-mongo");

const { CRUD } = require("qwebs-mongo");
 
class Api extends CRUD {
    constructor($mongo) {
        super("collectionName", $mongo);
    };
 
    /* manage skip and limit as querystring */
    httpStream(request, response) {
        request.mongo = {   //define mongo query, options,...
            options: {
              limit: parseInt(request.query.limit),
              skip: parseInt(request.query.skip)
            }
        }
        return super.httpStream(request, response);
    }

/* no extend -> custom implementation */
class Api {
  constructor($mongo) {
    this.$mongo = $mongo;
  };
 
  httpStream(request, response) {
    return this.$mongo.db.then(db => {
      const limit = parseInt(request.query.limit);
      const skip = parseInt(request.query.skip);
      const stream = db.collection("collectionName").find({}).limit(limit).skip(skip).stream();
      return response.send({ request: request, stream: stream });
    });
  );
};