Backup_Repos/beets
1
0
Fork 0
mirror of https://github.com/beetbox/beets.git synced 2026-01-05 23:43:31 +01:00
Code Issues Projects Releases Wiki Activity

fixed issue in pipeline when the first coro sends the BUBBLE message

Browse source
This commit is contained in:
Peter B 2011-04-11 12:31:17 -04:00
parent 7503c1174a
commit e7782cc369
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
beets/util/pipeline.py
View file

@ -99,10 +99,10 @@ class FirstPipelineThread(PipelineThread):
return
# Send it to the next stage.
self.out_queue.put(msg)
if msg is BUBBLE:
continue
self.out_queue.put(msg)
# Generator finished; shut down the pipeline.
self.out_queue.put(POISON)