fix(GermanBusinessData): Add console log for total records processed at the end of the stream.
This commit is contained in:
parent
b67e18f2fe
commit
555e156b5e
@ -1,5 +1,10 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2025-01-01 - 1.1.5 - fix(GermanBusinessData)
|
||||||
|
Add console log for total records processed at the end of the stream.
|
||||||
|
|
||||||
|
- Ensure that the number of records processed is logged at the end of data stream processing.
|
||||||
|
|
||||||
## 2024-12-31 - 1.1.4 - fix(documentation)
|
## 2024-12-31 - 1.1.4 - fix(documentation)
|
||||||
Update description and keywords in package.json
|
Update description and keywords in package.json
|
||||||
|
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@fin.cx/opendata',
|
name: '@fin.cx/opendata',
|
||||||
version: '1.1.4',
|
version: '1.1.5',
|
||||||
description: 'A TypeScript library for accessing, managing, and updating open business data, focused on German companies and integrating with MongoDB.'
|
description: 'A TypeScript library for accessing, managing, and updating open business data, focused on German companies and integrating with MongoDB.'
|
||||||
}
|
}
|
||||||
|
@ -64,6 +64,7 @@ export class GermanBusinessData {
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
finalFunction: async (streamToolsArg) => {
|
finalFunction: async (streamToolsArg) => {
|
||||||
|
console.log(`finished processing ${totalRecordsCounter} records.`);
|
||||||
if (!nextRest) return;
|
if (!nextRest) return;
|
||||||
JSON.parse(nextRest);
|
JSON.parse(nextRest);
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user