(self)
| 233 | yield dp |
| 234 | |
| 235 | def reset_state(self): |
| 236 | assert not self._reset_done, "reset_state() was called twice! This violates the API of DataFlow!" |
| 237 | self._reset_done = True |
| 238 | start_proc_mask_signal(self.procs) |
| 239 | |
| 240 | |
| 241 | class MultiProcessRunnerZMQ(_MultiProcessZMQDataFlow): |
nothing calls this directly
no test coverage detected