implement queue for travel time promises

CityofToronto · Jul 11, 2024 · b90a323 · b90a323
1 parent aba76c4
commit b90a323
Show file tree

Hide file tree

Showing 3 changed files with 38 additions and 2 deletions.
diff --git a/frontend/package-lock.json b/frontend/package-lock.json
diff --git a/frontend/package.json b/frontend/package.json
@@ -46,6 +46,7 @@
         "@mui/material": "5.x",
         "express": "^4.18.2",
         "leaflet": "^1.9.4",
+        "p-queue": "^8.0.1",
         "react": "18.x",
         "react-calendar": "^4.6.1",
         "react-date-picker": "^8.4.0",

diff --git a/frontend/src/spatialData.js b/frontend/src/spatialData.js
@@ -5,6 +5,9 @@ import { Days } from './days.js'
 import { HolidayOption } from './holidayOption.js'
 import { TravelTimeQuery } from './travelTimeQuery.js'
 import { domain } from './domain.js'
+import PQueue from 'p-queue'
+
+const queue = new PQueue({concurrency: 3})
 
 // instantiated once, this is the data store for all spatial and temporal data
 export class SpatialData {
@@ -116,10 +119,10 @@ export class SpatialData {
         return [...this.#queries.values()].sort((a,b)=> a.URI < b.URI ? -1 : 1)
     }
     fetchAllResults(){
-        return Promise.all(
+        return queue.addAll(
             this.travelTimeQueries
                 .filter( TTQ => ! TTQ.hasData )
-                .map( TTQ => TTQ.fetchData() )
+                .map( TTQ => () => TTQ.fetchData() )
         )
     }
 }