Example: Working with MongoDB Streams

PetController.ts

@Get('/hello-world-streams')
async streams() {
  // Get Mongodb cursor
  const cursor = this.repository.getCursorToAllRecords();

  const promise = new Promise((resolve, reject) => {
    cursor.on('data', doc => {
      console.log(doc);
    });

    cursor.on('close', () => {
      resolve();
    });

    cursor.on('error', error => {
      reject(error);
    });
  });

  return await promise.then(() => {
    return 'Stream was closed';
  }).catch(_error => {
    return 'Ops, something is wrong';
  });
}