Use process_buffer from backend instance

pya/arecorder.py

@@ -12,15 +12,6 @@
 _LOGGER = logging.getLogger(__name__)
 _LOGGER.addHandler(logging.NullHandler())
 
-PYAUDIO_PACONTINUE = 0
-try:
-    import pyaudio
-except ImportError:
-    pass
-else:
-    assert PYAUDIO_PACONTINUE == pyaudio.paContinue
-
-
 class Arecorder(Aserver):
     """pya audio recorder Based on pyaudio, uses callbacks to save audio data
     for pyaudio signals into ASigs
@@ -115,7 +106,7 @@ def _recorder_callback(self, in_data, frame_count, time_info, flag):
             self.record_buffer.append(data_float)
             # E = 10 * np.log10(np.mean(data_float ** 2)) # energy in dB
             # os.write(1, f"\r{E}    | {self.block_cnt}".encode())
-        return None, PYAUDIO_PACONTINUE
+        return self.backend.process_buffer(None)
 
     def record(self):
         """Activate recording"""