Method
__init__
(self, in_buffer_size: int = 1, out_buffer_size: int = 1)
Source from the content-addressed store, hash-verified
| 482 | Ungroups every batch (a list of items) into individual items and passes them to successive nodes. |
| 483 | """ |
| 484 | def __init__(self, in_buffer_size: int = 1, out_buffer_size: int = 1): |
| 485 | super().__init__('thread', in_buffer_size, out_buffer_size) |
| 486 | |
| 487 | def _loop_fn(self, input: Queue, output: Queue, terminate_flag: Event): |
| 488 | try: |
Callers
nothing calls this directly
Tested by
no test coverage detected