merge Lugoues' pipeline fix

This commit is contained in:
Adrian Sampson 2011-04-11 09:43:25 -07:00
commit 5d22405e63

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)