(self, sample_rate: int, prebuffer_seconds: float)
| 236 | |
| 237 | class StreamAudioEmitter: |
| 238 | def __init__(self, sample_rate: int, prebuffer_seconds: float): |
| 239 | self.sample_rate = sample_rate |
| 240 | self._buffer_tracker = BufferedAudioTracker(sample_rate) |
| 241 | self._prebuffer_target = max(0.0, float(prebuffer_seconds)) |
| 242 | self._prebuffering = self._prebuffer_target > 0.0 |
| 243 | self._pending_chunks: list[np.ndarray] = [] |
| 244 | self._pending_samples = 0 |
| 245 | self.chunk_count = 0 |
| 246 | self.has_audio = False |
| 247 | |
| 248 | def wait_for_capacity(self, threshold_seconds: float) -> None: |
| 249 | _maybe_wait_for_buffer(self._buffer_tracker, threshold_seconds) |
nothing calls this directly
no test coverage detected