fix(json): replace concatMap with mergeMap for improved data handling

Author: StephanGerbeth

packages/operators/src/json.js

@@ -1,4 +1,4 @@
-import { concatAll, concatMap, from, map, Observable, of, toArray } from 'rxjs';
+import { concatAll, concatMap, from, map, mergeMap, Observable, of, toArray } from 'rxjs';
 
 import { createAsyncReplacer, createSyncReplacer } from './json/replacer.js';
 import { createAsyncReviver, createSyncReviver } from './json/reviver.js';
@@ -52,7 +52,7 @@ export const parse = syncTransforms => source =>
 
 const traverse = transforms => source =>
   source.pipe(
-    concatMap(data => of(data).pipe(getOperator(data)(transforms))),
+    mergeMap(data => of(data).pipe(getOperator(data)(transforms))),
     transform(transforms)
     //
   );

packages/operators/src/json.test.js

@@ -37,14 +37,19 @@ describe('log', () => {
     ];
 
     const data = Promise.resolve({
+      image: new Promise(resolve =>
+        setTimeout(
+          () => resolve(readFile('./packages/operators/fixtures/images/test_image.jpg')),
+          1000
+        )
+      ),
       text: Promise.resolve('hello world'),
       bigInt: BigInt(123),
       date: new Date(),
       url: new URL('https://example.com'),
       regexp: /\w/g,
       globalSymbol: Symbol.for('foo'),
       symbol: Symbol('bar'),
-      image: readFile('./packages/operators/fixtures/images/test_image.jpg'),
       array: [
         Promise.resolve('hello world'),
         BigInt(123),
@@ -55,14 +60,19 @@ describe('log', () => {
         Symbol('bar')
       ],
       nested: of({
+        image: new Promise(resolve =>
+          setTimeout(
+            () => resolve(readFile('./packages/operators/fixtures/images/test_image.jpg')),
+            1000
+          )
+        ),
         text: Promise.resolve('hello world'),
         bigInt: BigInt(123),
         date: new Date(),
         url: new URL('https://example.com'),
         regexp: Promise.resolve(new RegExp('\\w', 'g')),
         globalSymbol: Symbol.for('foo'),
-        symbol: Symbol('bar'),
-        image: from(readFile('./packages/operators/fixtures/images/test_image.jpg'))
+        symbol: Symbol('bar')
       })
     });
     console.log('DATA', data);