From cb3cb50cbd7a49523d3f6e4d066dd1f5a7042288 Mon Sep 17 00:00:00 2001 From: Jakob Ketterl Date: Sun, 11 Apr 2021 20:10:49 +0200 Subject: [PATCH] fix chopper startup --- owrx/audio/chopper.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/owrx/audio/chopper.py b/owrx/audio/chopper.py index 52bbfa8..879fd0e 100644 --- a/owrx/audio/chopper.py +++ b/owrx/audio/chopper.py @@ -34,9 +34,10 @@ class AudioChopper(threading.Thread, Output, ProfileSourceSubscriber): self.stop_writers() sorted_profiles = sorted(self.profile_source.getProfiles(), key=lambda p: p.getInterval()) groups = {interval: list(group) for interval, group in groupby(sorted_profiles, key=lambda p: p.getInterval())} - self.writers = [AudioWriter(self.dsp, interval, profiles) for interval, profiles in groups.items()] - for w in self.writers: + writers = [AudioWriter(self.dsp, interval, profiles) for interval, profiles in groups.items()] + for w in writers: w.start() + self.writers = writers self.writersChangedOut.send(None) def supports_type(self, t): @@ -48,7 +49,7 @@ class AudioChopper(threading.Thread, Output, ProfileSourceSubscriber): def run(self) -> None: logger.debug("Audio chopper starting up") - self.writersChangedOut, self.writersChangedIn = Pipe() + self.writersChangedIn, self.writersChangedOut = Pipe() self.setup_writers() self.profile_source.subscribe(self) while self.doRun: