(self)
| 229 | break |
| 230 | |
| 231 | def flush(self) -> Iterator[np.ndarray]: |
| 232 | final_chunk = self.decoder.flush() |
| 233 | if final_chunk is not None and final_chunk.numel() > 0: |
| 234 | yield final_chunk.detach().cpu().numpy().reshape(-1) |
| 235 | |
| 236 | |
| 237 | class StreamAudioEmitter: |
no outgoing calls
no test coverage detected