File tree Expand file tree Collapse file tree 1 file changed +3
-7
lines changed
Expand file tree Collapse file tree 1 file changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -493,15 +493,11 @@ def value(self):
493493
494494 def fill (self ):
495495 try :
496- while (not self .stopping .wait (self .sample_wait ) and
497- len (self .queue ) < self .queue .maxlen ):
498- self .queue .append (self .parent ._read ())
499- if self .partial and isinstance (self .parent , EventsMixin ):
500- self .parent ._fire_events ()
501- self .full .set ()
502496 while not self .stopping .wait (self .sample_wait ):
503497 self .queue .append (self .parent ._read ())
504- if isinstance (self .parent , EventsMixin ):
498+ if not self .full .is_set () and len (self .queue ) >= self .queue .maxlen :
499+ self .full .set ()
500+ if (self .partial or self .full .is_set ()) and isinstance (self .parent , EventsMixin ):
505501 self .parent ._fire_events ()
506502 except ReferenceError :
507503 # Parent is dead; time to die!
You can’t perform that action at this time.
0 commit comments