Fixing CAAQM adapter, WIP

signicode · Dec 5, 2018 · 3c471a1 · 3c471a1
1 parent 34b54d2
commit 3c471a1
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/adapters/caaqm.js b/adapters/caaqm.js
@@ -36,8 +36,16 @@ export async function fetchStream (source) {
 
   return DataStream
     .from(
-      request(options)
-        .pipe(JSONStream.parse('map.station_list.*'))
+      () => {
+        const response = request(options);
+        const parser = JSONStream.parse('map.station_list.*');
+        const output = new DataStream();
+
+        parser.on('error', (e) => output.raise(e));
+        response.on('error', (e) => output.raise(e));
+
+        return response.pipe(parser).pipe(output);
+      }
     )
     .setOptions({maxParallel: 5})
     .into(