| 207 | |
| 208 | |
| 209 | class ProviderFunction(Provider): |
| 210 | def __init__(self, fn: Callable, running_as: 'thread', out_buffer_size: int = 1) -> None: |
| 211 | super().__init__(running_as, out_buffer_size) |
| 212 | self.fn = fn |
| 213 | |
| 214 | def provide(self): |
| 215 | for item in self.fn(): |
| 216 | yield item |
| 217 | |
| 218 | |
| 219 | class Link: |