(self, local_init_net, local_finish_net)
| 507 | self.reader.setup_ex(global_init_net, global_finish_net) |
| 508 | |
| 509 | def read_ex(self, local_init_net, local_finish_net): |
| 510 | read_net = core.Net("reader_body") |
| 511 | |
| 512 | def sleep_op(*args, **argd): |
| 513 | time.sleep(self.delay) |
| 514 | |
| 515 | read_net.Python(sleep_op)([], []) |
| 516 | return ([read_net],) + self.reader.read(read_net) |
| 517 | |
| 518 | |
| 519 | class CompositeReader(Reader): |