@ -113,6 +113,7 @@ class ThreadedPipeline:
# TODO: this might not all be necessary
def stop(self):
if self._stopper.is_set():
self._stopper.set()
self._pipeline.set_state(Gst.State.NULL)
logger.debug('Shut down gstreamer pipeline: %s', self._pipeline.get_name())