Loop ajax requests with Rxjs

emails.js

var array = ["[email protected]", "[email protected]"];

const emails = () => array;

module.exports = emails;

index.js

const Rx = require('rxjs/Rx');
const axios = require('axios');
const emails = require('./emails');

let array = emails();

let baseUrl = "https://api-staging.antelopesystem.com/SignalsServer/users/forgotpassword?appId=1&email=";

//we use flatMap becuase order doesnt matter
//https://www.learnrxjs.io/operators/transformation/mergemap.html
var source = Rx.Observable.from(array).flatMap((email) => {
    return Rx.Observable.fromPromise(axios.get(`${baseUrl}${email}`).then((res) => {
        console.log(`completed with ${email}`);
        return res;
    })).delay(30)
});

var subscription = source.subscribe(
    (x) => {},
    (err) => {},
    () => console.log('Completed'));