refactor(transducers-fsm): use arrow fns

thi-ng · Jan 5, 2019 · e103d74 · e103d74
1 parent 48670f5
commit e103d74
Showing 1 changed file with 21 additions and 21 deletions.
diff --git a/packages/transducers-fsm/src/index.ts b/packages/transducers-fsm/src/index.ts
@@ -92,26 +92,26 @@ export interface FSMOpts<T extends FSMState, A, B> {
  *
  * @param opts
  */
-export function fsm<T extends FSMState, A, B>(opts: FSMOpts<T, A, B[]>): Transducer<A, B> {
-    return comp((rfn: Reducer<any, B>) => {
-        const states = opts.states;
-        const state = opts.init();
-        const r = rfn[2];
-        return compR(rfn,
-            (acc, x) => {
-                const res = states[<any>state.state](state, x);
-                if (res != null) {
-                    for (let i = 0, n = (<B[]>res).length; i < n; i++) {
-                        acc = r(acc, res[i]);
-                        if (isReduced(acc)) {
-                            break;
+export const fsm =
+    <T extends FSMState, A, B>(opts: FSMOpts<T, A, B[]>): Transducer<A, B> =>
+        comp((rfn: Reducer<any, B>) => {
+            const states = opts.states;
+            const state = opts.init();
+            const r = rfn[2];
+            return compR(rfn,
+                (acc, x) => {
+                    const res = states[<any>state.state](state, x);
+                    if (res != null) {
+                        for (let i = 0, n = (<B[]>res).length; i < n; i++) {
+                            acc = r(acc, res[i]);
+                            if (isReduced(acc)) {
+                                break;
+                            }
                         }
                     }
-                }
-                if (state.state === opts.terminate) {
-                    return ensureReduced(acc);
-                }
-                return acc;
-            });
-    });
-}
+                    if (state.state === opts.terminate) {
+                        return ensureReduced(acc);
+                    }
+                    return acc;
+                });
+        });