(self, iterable: Iterable[T], buffer_size: int)
| 491 | |
| 492 | class BufferedIterator(Generic[T]): |
| 493 | def __init__(self, iterable: Iterable[T], buffer_size: int): |
| 494 | self.iterator = iter(iterable) |
| 495 | self.buffer = deque(maxlen=buffer_size) |
| 496 | self.buffer_size = buffer_size |
| 497 | self.lock = threading.Lock() |
| 498 | self.exhausted = False |
| 499 | self.filler_thread = threading.Thread(target=self._background_fill, daemon=True) |
| 500 | self.filler_thread.start() |
| 501 | |
| 502 | def _background_fill(self): |
| 503 | # Fill up the buffer, whenever possible, in the background |
nothing calls this directly
no outgoing calls
no test coverage detected