openwebrx-clone/csdr/chain/__init__.py

36 lines
866 B
Python
Raw Normal View History

2021-01-02 02:12:21 +00:00
from pycsdr.modules import Buffer
from pycsdr.api import Flow
import logging
logger = logging.getLogger(__name__)
2021-01-02 02:12:21 +00:00
class Chain(Flow):
2020-12-16 17:52:00 +00:00
def __init__(self, *workers):
self.input = None
self.output = None
2020-12-16 17:52:00 +00:00
self.workers = workers
for i in range(1, len(self.workers)):
self._connect(self.workers[i - 1], self.workers[i])
def _connect(self, w1, w2):
buffer = Buffer()
w1.setOutput(buffer)
w2.setInput(buffer)
2020-12-16 17:52:00 +00:00
def stop(self):
for w in self.workers:
w.stop()
def setInput(self, buffer):
if self.input == buffer:
return
self.input = buffer
self.workers[0].setInput(buffer)
def setOutput(self, buffer):
if self.output == buffer:
return
self.output = buffer
self.workers[-1].setOutput(buffer)