(self, reader, delay)
| 499 | """Test reader class that inserts a delay between reading batches.""" |
| 500 | |
| 501 | def __init__(self, reader, delay): |
| 502 | Reader.__init__(self, schema=reader._schema) |
| 503 | self.reader = reader |
| 504 | self.delay = delay |
| 505 | |
| 506 | def setup_ex(self, global_init_net, global_finish_net): |
| 507 | self.reader.setup_ex(global_init_net, global_finish_net) |