如何使用NodeJs中的rxjs中的forkjoin进行多次调用，使用NPM请求

Question

我必须使用request module和RxJs Observable在NodeJs中在服务器端进行多个序列化调用

我有像''www.google.com'，'facebook.com'这样的Url地址数组。当我发出请求呼叫时，服务器在事件循环中忙碌。我想知道我的最后一个url调用何时获得响应，以便我可以向前端发送响应，这是我的代码到目前为止

 const foo = Observable.create(function (observer) {
         res.writeHeader(200, { "Content-Type": "text/html" });
         var str = '<html><head></head><body><h1> Following are the responses: </h1><ul>'
         res.write(str);
         let count = 0;
         addressesArray.forEach(function (element, i) {

         observer.next(element);
         if (some Condition) {
            console.log('here i want to call complete when I get last response')     
       // observer.complete();   
         }


         })
     })

这是我的订阅功能

     const subscription = foo.subscribe({
         next : addres =>
         {
             request(addres , function (error, response, body) {
                if (!error && response.statusCode == 200) {

                     console.log(response)


                 }
                if (typeof response === "undefined" || typeof body === "undefined") {
                     console.log('No resp')
                 }
            })

     },
     complete:()=>{console.log('done')}


 })

我怎么能用Forkjoin呢