()
| 217 | handle.close() |
| 218 | |
| 219 | def setup(): |
| 220 | tmpdir = TemporaryDirectory() |
| 221 | input_paths = start_write_threads(tmpdir.name, 5) |
| 222 | |
| 223 | handles = [] |
| 224 | for path in input_paths: |
| 225 | handle = open(path, "rb") |
| 226 | handles.append(handle) |
| 227 | |
| 228 | Thread(target=close_all, args=(handles,)).start() |
| 229 | |
| 230 | output_path = os.path.join(tmpdir.name, "merged") |
| 231 | return tmpdir, input_paths, handles, output_path |
| 232 | |
| 233 | |
| 234 | print("Example 10") |
no test coverage detected