Method start

inference_client.py:96–132

(self)

                    self.output_queue.put(processed_audio)
    
    def start(self):
        self.running = True
        # Print audio device information
        devices = sd.query_devices()
        default_input = sd.query_devices(kind='input')
        default_output = sd.query_devices(kind='output')
        
        print("\nAudio Device Configuration:")
        print("-" * 50)
        print(f"Default Input Device:\n{default_input}\n")
        print(f"Default Output Device:\n{default_output}\n") 
        print("\nAll Available Devices:")
        print("-" * 50)
        for i, device in enumerate(devices):
            print(f"Device {i}:")
            print(f"Name: {device['name']}")
            print(f"Channels (in/out): {device['max_input_channels']}/{device['max_output_channels']}")
            print(f"Sample Rates: {device['default_samplerate']}")
            print()
        input_device = input("Enter the index of the input device or press enter for default: ")
        output_device = input("Enter the index of the output device or press enter for default: ")
        if input_device == "":
            input_device = default_input['index']
        if output_device == "":
            output_device = default_output['index']
        with sd.InputStream(callback=self.audio_callback,
                          channels=CHANNELS,
                          samplerate=SAMPLE_RATE,
                          device=int(input_device),
                          blocksize=2000), \
             sd.OutputStream(callback=self.output_stream_callback,
                           channels=CHANNELS,
                           samplerate=SAMPLE_RATE,
                           blocksize=2000,
                           device=int(output_device)):
            
            asyncio.run(self.process_audio())
    
    def stop(self):
        self.running = False