diff --git a/csdr/chain/__init__.py b/csdr/chain/__init__.py
new file mode 100644
index 0000000..b689125
--- /dev/null
+++ b/csdr/chain/__init__.py
@@ -0,0 +1,16 @@
+class Chain(object):
+    def __init__(self, *workers):
+        self.workers = workers
+        stage = None
+        for w in self.workers:
+            if stage is not None:
+                w.setInput(stage.getBuffer())
+            stage = w
+        self.buffer = stage.getBuffer()
+
+    def stop(self):
+        for w in self.workers:
+            w.stop()
+
+    def getBuffer(self):
+        return self.buffer
diff --git a/csdr/chain/fft.py b/csdr/chain/fft.py
new file mode 100644
index 0000000..bf90b15
--- /dev/null
+++ b/csdr/chain/fft.py
@@ -0,0 +1,15 @@
+from csdr.chain import Chain
+from pycsdr import SocketClient, Fft, LogAveragePower, FftExchangeSides, CompressFftAdpcm
+
+
+class FftChain(Chain):
+    def __init__(self, port, fft_size, fft_block_size, fft_averages, fft_compression):
+        workers = [
+            SocketClient(port=port),
+            Fft(size=fft_size, every_n_samples=int(fft_block_size)),
+            LogAveragePower(add_db=-70, fft_size=fft_size, avg_number=fft_averages),
+            FftExchangeSides(fft_size=fft_size),
+        ]
+        if fft_compression == "adpcm":
+            workers += [CompressFftAdpcm(fft_size=fft_size)]
+        super().__init__(*workers)
diff --git a/csdr/csdr.py b/csdr/csdr.py
index 1a2e67b..aab92fb 100644
--- a/csdr/csdr.py
+++ b/csdr/csdr.py
@@ -34,8 +34,7 @@ from owrx.js8 import Js8Profiles
 from owrx.audio import AudioChopper
 
 from csdr.pipe import Pipe
-
-from pycsdr import SocketClient, Fft, LogAveragePower, FftExchangeSides
+from csdr.chain.fft import FftChain
 
 import logging
 
@@ -77,6 +76,7 @@ class output(object):
 class dsp(object):
     def __init__(self, output):
         self.pycsdr_enabled = True
+        self.pycsdr_chain = None
 
         self.samp_rate = 250000
         self.output_rate = 11025
@@ -765,18 +765,15 @@ class dsp(object):
                         return
                     self.running = True
 
-                nc = SocketClient(self.nc_port)
+                self.pycsdr_chain = FftChain(
+                    port=self.nc_port,
+                    fft_size=self.fft_size,
+                    fft_block_size=self.fft_block_size(),
+                    fft_averages=self.fft_averages,
+                    fft_compression=self.fft_compression
+                )
 
-                fft = Fft(self.fft_size, int(self.fft_block_size()))
-                fft.setInput(nc.getBuffer())
-
-                lap = LogAveragePower(-70, self.fft_size, self.fft_averages)
-                lap.setInput(fft.getBuffer())
-
-                fes = FftExchangeSides(fft_size=self.fft_size)
-                fes.setInput(lap.getBuffer())
-
-                self.output.send_output("audio", fes.getBuffer().read)
+                self.output.send_output("audio", self.pycsdr_chain.getBuffer().read)
 
                 return
         with self.modification_lock:
@@ -883,6 +880,8 @@ class dsp(object):
     def stop(self):
         with self.modification_lock:
             self.running = False
+            if self.pycsdr_enabled and self.pycsdr_chain is not None:
+                self.pycsdr_chain.stop()
             if self.process is not None:
                 try:
                     os.killpg(os.getpgid(self.process.pid), signal.SIGTERM)