File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -12,6 +12,7 @@ var userQueue = []
12
12
var has = { }
13
13
var waiting = false
14
14
var flushing = false
15
+ var internalQueueDepleted = false
15
16
16
17
/**
17
18
* Reset the batcher's state.
@@ -21,8 +22,7 @@ function reset () {
21
22
queue = [ ]
22
23
userQueue = [ ]
23
24
has = { }
24
- waiting = false
25
- flushing = false
25
+ waiting = flushing = internalQueueDepleted = false
26
26
}
27
27
28
28
/**
@@ -32,6 +32,7 @@ function reset () {
32
32
function flush ( ) {
33
33
flushing = true
34
34
run ( queue )
35
+ internalQueueDepleted = true
35
36
run ( userQueue )
36
37
reset ( )
37
38
}
@@ -81,7 +82,7 @@ exports.push = function (job) {
81
82
// directive update during the flushing; at that time
82
83
// the directive queue would already have been run, so
83
84
// we call that update immediately as it is pushed.
84
- if ( flushing && ! job . user ) {
85
+ if ( flushing && ! job . user && internalQueueDepleted ) {
85
86
job . run ( )
86
87
return
87
88
}
You can’t perform that action at this time.
0 commit comments