(self)
| 155 | yield wav.detach().cpu().numpy().reshape(-1) |
| 156 | |
| 157 | def flush(self) -> Iterator[np.ndarray]: |
| 158 | final_chunk = self.decoder.flush() |
| 159 | if final_chunk is not None and final_chunk.numel() > 0: |
| 160 | self._mark_started() |
| 161 | yield final_chunk.detach().cpu().numpy().reshape(-1) |
| 162 | self.finish() |
| 163 | |
| 164 | |
| 165 | def _maybe_wait_for_buffer(buffer_tracker: BufferedAudioTracker, threshold_seconds: float) -> None: |
no test coverage detected