Add scenarioOnEvery util

Signed-off-by: Yuriy Yakym <[email protected]>

src/index.ts

@@ -1,4 +1,12 @@
-export { AwaitableEvent, composeState, delay, scenario, scenarioOnce, rejectAfter } from './lib';
+export {
+  AwaitableEvent,
+  composeState,
+  delay,
+  rejectAfter,
+  scenario,
+  scenarioOnce,
+  scenarioOnEvery,
+} from './lib';
 export { default as action } from './action';
 export { default as state } from './state';
 export { default as useFlowValue } from './useFlowValue';

src/lib/index.ts

@@ -2,6 +2,7 @@ export { default as AwaitableEvent } from './AwaitableEvent';
 export { default as composeState } from './composeState';
 export { default as delay } from './delay';
 export { default as noop } from './noop';
+export { default as rejectAfter } from './rejectAfter';
 export { default as scenario } from './scenario';
 export { default as scenarioOnce } from './scenarioOnce';
-export { default as rejectAfter } from './rejectAfter';
+export { default as scenarioOnEvery } from './scenarioOnEvery';

src/lib/scenarioOnEvery.ts

@@ -0,0 +1,14 @@
+import AwaitableEvent from './AwaitableEvent';
+import noop from './noop';
+
+const scenarioOnEvery = async <T>(
+  awaitableEvent: AwaitableEvent<T>,
+  scenarioFn: (event: T) => Promise<any>,
+) => {
+  while (true) {
+    const event = await awaitableEvent;
+    scenarioFn(event).catch(noop);
+  }
+};
+
+export default scenarioOnEvery;