catch errors in stringStream

openaq · Apr 12, 2024 · 7953f11 · 7953f11
1 parent 6f60e06
commit 7953f11
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/adapters/arpalazio.js b/src/adapters/arpalazio.js
@@ -158,6 +158,9 @@ export const getStream = function (
   const stations = {};
   return StringStream.from(getter.stream(url))
     .lines(StringStream.SPLIT_LINE)
+    .catch((error) => {
+      log.error('Stream error: ', error);
+    })
     .map((x) => x.replace(/\s+/g, ' ').replace(/^\s+|\s+$/g, ''))
     .parse((row) => row.trim().split(/\s+/g))
     .shift(1, ([header]) => {