【BUG】AudioConsumer 中 consume 方法是不是存在无法完整消费剩余数据的情况？

[othorizon]

Agora-Python-Server-SDK/agora_rtc/agora/rtc/utils/audio_consumer.py

Line 86 in 2426ade

if besent_packages > AudioConsumer.MIN_BUFFER_SIZE and data_len //self._bytes_per_frame < AudioConsumer.MIN_BUFFER_SIZE: #for fist time, if data_len is not enough, just return and wait for next time

在这个文件中

class AudioConsumer:
    def consume(self):
       //....something
        if besent_packages > AudioConsumer.MIN_BUFFER_SIZE and data_len //self._bytes_per_frame < AudioConsumer.MIN_BUFFER_SIZE: #for fist time, if data_len is not enough, just return and wait for next time
            #print("-----underflow data")
            return -2

这里虽然注释说只有第一次会触发，但是如果我推送结束后，不再有新的数据继续推送，但是剩余数据又不足一个发送包，并且没有 release 的情况下。这里会一直返回 -2 。也就是说在release 之前我无法通过is_push_to_rtc_completed 或者 len() 正确的判断是否发送完成。

[shaojun]

同样有类似的问题, 以下是我的示例代码, 用于判断当前是否仍然在往channel中发送音频数据, 并将此状态将记录在self.rtc_audio_consumer_state中:

                while not self._stop_agora_conn_event.is_set():
                    if self.audio_consumer and self.audio_consumer.len() > 0:
                        self.audio_consumer.consume()
                        if self.rtc_audio_consumer_state == "idle":
                            self.rtc_audio_consumer_state = "consuming"
                    else:
                        if self.rtc_audio_consumer_state == "consuming":
                            self.rtc_audio_consumer_state = "idle"                            
                    time.sleep(0.06)

通过测试, 我发现哪怕对话早就结束了, 但self.rtc_audio_consumer_state会一直是consuming状态,这说明self.audio_consumer.len() > 0一直是true的.