(self)
| 221 | self.assertEqual({"mike", "test", "hello world"}, set(self.alt.list())) |
| 222 | |
| 223 | def test_threaded_reads(self): |
| 224 | self.fs.put(b"hello", _id="test") |
| 225 | |
| 226 | tasks = [] |
| 227 | results: list = [] |
| 228 | for i in range(10): |
| 229 | tasks.append(JustRead(self.fs, 10, results)) |
| 230 | tasks[i].start() |
| 231 | |
| 232 | joinall(tasks) |
| 233 | |
| 234 | self.assertEqual(100 * [b"hello"], results) |
| 235 | |
| 236 | def test_threaded_writes(self): |
| 237 | tasks = [] |