use switch map to implement reset

src/strategies.js

@@ -1,11 +1,11 @@
 import { merge, of } from 'rxjs';
 import {
   concat,
-  concatMap,
+  switchMap,
   concatMapTo,
   filter,
   map,
-  scan
+  scan,
 } from 'rxjs/operators';
 
 module.exports = function () {
@@ -113,18 +113,20 @@ module.exports = function () {
         )
       );
       const reset$ = this.reset$;
-      return merge(source$.pipe(
-          concatMap(data =>
-            of(data).pipe(
-              concat(
-                events$.pipe(
-                  scan((current, callback) => sortAndTrim(callback(current)), data))
+      return merge(source$, reset$.pipe(concatMapTo(source$))).pipe(
+        switchMap((data) =>
+          of(data).pipe(
+            concat(
+              events$.pipe(
+                scan(
+                  (current, callback) => sortAndTrim(callback(current)),
+                  data
+                )
               )
-            ),
-          ),
-        ),
-        reset$.pipe(concatMapTo(source$))
+            )
+          )
         )
+      );
     }
   };
 };