(self)
| 13 | self.worker = worker |
| 14 | |
| 15 | def base_case(self): |
| 16 | queue = Queue() |
| 17 | t = EHThread(target=self.worker, args=[queue]) |
| 18 | t.start() |
| 19 | t.join() |
| 20 | assert queue.get(block=False) == 7 |
| 21 | assert queue.empty() |
| 22 | |
| 23 | def catches_exceptions(self): |
| 24 | # Induce exception by submitting a bad queue obj |