throttle fix

psharanda · Apr 26, 2017 · f072a4a · f072a4a
1 parent 74f871f
commit f072a4a
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/Sources/Observable+Filtering.swift b/Sources/Observable+Filtering.swift
@@ -31,13 +31,12 @@ extension Observable {
             return self.subscribe { result in
                 let newDate = Date()
                 lastIgnoredValue = result
+                lastAfterCancel?.dispose()
+                lastAfterCancel = nil
                 if newDate.timeIntervalSince(lastUpdateTime) >= timeInterval {
-                    lastAfterCancel?.dispose()
-                    lastAfterCancel = nil
                     lastUpdateTime = newDate
                     lastIgnoredValue = nil
-                    observer(result)
-
+                    observer(result)                    
                     if latest {
                         lastAfterCancel = queue.jx_after(timeInterval: timeInterval) {
                             guard let lastIgnoredValue = lastIgnoredValue  else { return }