()
| 135 | handle.close() |
| 136 | |
| 137 | def setup(): |
| 138 | tmpdir = TemporaryDirectory() |
| 139 | input_paths = start_write_threads(tmpdir.name, 5) |
| 140 | |
| 141 | handles = [] |
| 142 | for path in input_paths: |
| 143 | handle = open(path, "rb") |
| 144 | handles.append(handle) |
| 145 | |
| 146 | Thread(target=close_all, args=(handles,)).start() |
| 147 | |
| 148 | output_path = os.path.join(tmpdir.name, "merged") |
| 149 | return tmpdir, input_paths, handles, output_path |
| 150 | |
| 151 | |
| 152 | print("Example 5") |
no test coverage detected