(self, src, buffer_size: int = 1, timeout: float = 0.01)
| 38 | """ |
| 39 | |
| 40 | def __init__(self, src, buffer_size: int = 1, timeout: float = 0.01): |
| 41 | self.src = src |
| 42 | self.buffer_size = buffer_size |
| 43 | self.timeout = timeout |
| 44 | self.buffer: Queue = Queue(self.buffer_size) |
| 45 | self.gen_thread: Thread | None = None |
| 46 | self.is_running = False |
| 47 | |
| 48 | def enqueue_values(self): |
| 49 | for src_val in self.src: |