Example mssql query to observable stream

getusers.ts

import { ConnectionPool } from 'mssql';

export class DatabaseClient {
  pool: ConnectionPool;
  dbConfig: {redated};
  constructor() {
    super();
    this.pool = new ConnectionPool(this.dbConfig);
  }

  getUsers$ = (): Observable<any> => from(this.pool.connect()).pipe(
    switchMap(() => {
      const request = this.pool.request();
      return from(request.query("SELECT email, name FROM users")).pipe(
        pluck('recordset'),
        mergeAll()
      );
    })
  );
}