From 05ef57bebd4d1058018eecbb7526fec7a7f5914d Mon Sep 17 00:00:00 2001 From: petrucci4prez Date: Sat, 3 Jun 2017 22:36:46 -0400 Subject: [PATCH] fix loop exit bug --- stream.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream.py b/stream.py index bcee1ae..2220498 100644 --- a/stream.py +++ b/stream.py @@ -93,7 +93,7 @@ class ThreadedPipeline: pName = self._pipeline.get_name() bus = self._pipeline.get_bus() - while self._stopper: + while not self._stopper.isSet(): # TODO: if we actually want to stop the pipeline asyncronously we # need to post a message on the bus that tells it to stop. Otherwise # it will wait here forever (or will be terminated as a daemon