Implements enough protocol to test concurrency semantics.
| 5 | |
| 6 | |
| 7 | class FakeTarPartition(object): |
| 8 | """Implements enough protocol to test concurrency semantics.""" |
| 9 | def __init__(self, num_members, explosive=False): |
| 10 | self._explosive = explosive |
| 11 | self.num_members = num_members |
| 12 | |
| 13 | def __len__(self): |
| 14 | return self.num_members |
| 15 | |
| 16 | |
| 17 | class FakeUploader(object): |
no outgoing calls