(self)
| 120 | self.active_flows.discard(flow) |
| 121 | |
| 122 | def done(self) -> None: |
| 123 | if self.stream: |
| 124 | for f in self.active_flows: |
| 125 | self.stream.add(f) |
| 126 | self.active_flows.clear() |
| 127 | |
| 128 | self.current_path = None |
| 129 | self.stream.fo.close() |
| 130 | self.stream = None |
| 131 | |
| 132 | @command.command("save.file") |
| 133 | def save(self, flows: Sequence[flow.Flow], path: mitmproxy.types.Path) -> None: |