comparison src/app/services/feature-extraction/FeatureExtractionWorker.ts @ 323:72673c954216

Try chaining the list requests.

   addService(key: LibraryKey, service: Factory<PiperStreamingService>): void {
     this.services.set(key, service);
   }
 
   list(request: ListRequest): Promise<ListResponse> {
-    return Promise.all(
-      [...this.services.values()].map(client => client().list({}))
-    ).then(allAvailable => ({
-        available: allAvailable.reduce(
-          (all, current) => all.concat(current.available),
-          []
-        )
+    //TODO refactor
+    const listThunks: (() => Promise<ListResponse>)[] = [
+      ...this.services.values()
+    ].map(client => () => client().list({}));
+
+    const concatAvailable = (running: ListResponse,
+                             nextResponse: Promise<ListResponse>)
+      : Promise<ListResponse> => {
+      return nextResponse.then(response => {
+        running.available = running.available.concat(response.available);
+        return running;
+      });
+    };
+
+    return listThunks.reduce((runningResponses, nextResponse) => {
+      return runningResponses.then(response => {
+        return concatAvailable(response, nextResponse());
       })
-    );
+    }, Promise.resolve({available: []}));
   }
 
   process(request: SimpleRequest): Observable<StreamingResponse> {
     return this.dispatch('process', request);
   }

 
   private setupImportLibraryListener(): void {
 
     this.workerScope.onmessage = (ev: MessageEvent) => {
       const sendResponse = (result) => {
-        console.warn(ev.data.method);
+        console.warn(ev.data.method, ev.data);
         this.workerScope.postMessage({
           method: ev.data.method,
           result: result
         });
       };