fix: 🐛 loop lock

Inist-CNRS · Nov 29, 2024 · 81337b9 · 81337b9
1 parent 8525706
commit 81337b9
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/packages/conditor/src/openalex-fetch.js b/packages/conditor/src/openalex-fetch.js
@@ -108,8 +108,10 @@ export default async function OAFetch(data, feed) {
         const output = ezs.createStream(ezs.objectMode());
         const response = await retry(request(cURL.href, parameters), options);
         const { results, meta } = await response.json();
-        await loop(output, results, meta?.next_cursor);
-        await feed.flow(output);
+        await Promise.all([
+            loop(output, results, meta?.next_cursor),
+            feed.flow(output),
+        ]);
     } catch (e) {
         onError(e);
     }

diff --git a/packages/conditor/test/oa-fetch.js b/packages/conditor/test/oa-fetch.js
@@ -8,7 +8,7 @@ describe('openalexfetch', () => {
         const input = [
             {
                 filter: 'authorships.author.id:a5000387389',
-                'per-page': 20,
+                'per-page': 200,
             },
         ];
         const output = [];