fix(overmind): fix throttle operator

christianalfoni · christianalfoni · commit 1df8b811e42e · 2019-09-19T08:43:28.000+02:00
diff --git a/packages/node_modules/overmind/src/index.ts b/packages/node_modules/overmind/src/index.ts
@@ -1511,7 +1511,6 @@ export function throttle<Input, ThisConfig extends IConfiguration = Config>(
   ms: number
 ): IOperator<ThisConfig, Input, Input> {
   let timeout
-  let previousFinal
 
   return createOperator(
     'throttle',
@@ -1520,14 +1519,13 @@ export function throttle<Input, ThisConfig extends IConfiguration = Config>(
       if (err) next(err, value)
       else {
         if (timeout) {
-          previousFinal(null, value)
+          final(null, value)
         } else {
+          next(null, value)
           timeout = setTimeout(() => {
             timeout = null
-            next(null, value)
           }, ms)
         }
-        previousFinal = final
       }
     }
   )

Original file line number	Diff line number	Diff line change
`@@ -1511,7 +1511,6 @@ export function throttle<Input, ThisConfig extends IConfiguration = Config>(`
`1511`	`1511`	`ms: number`
`1512`	`1512`	`): IOperator<ThisConfig, Input, Input> {`
`1513`	`1513`	`let timeout`
`1514`		`- let previousFinal`
`1515`	`1514`
`1516`	`1515`	`return createOperator(`
`1517`	`1516`	`'throttle',`
`@@ -1520,14 +1519,13 @@ export function throttle<Input, ThisConfig extends IConfiguration = Config>(`
`1520`	`1519`	`if (err) next(err, value)`
`1521`	`1520`	`else {`
`1522`	`1521`	`if (timeout) {`
`1523`		`- previousFinal(null, value)`
	`1522`	`+ final(null, value)`
`1524`	`1523`	`} else {`
	`1524`	`+ next(null, value)`
`1525`	`1525`	`timeout = setTimeout(() => {`
`1526`	`1526`	`timeout = null`
`1527`		`- next(null, value)`
`1528`	`1527`	`}, ms)`
`1529`	`1528`	`}`
`1530`		`- previousFinal = final`
`1531`	`1529`	`}`
`1532`	`1530`	`}`
`1533`	`1531`	`)`