(self, flow: http.HTTPFlow)
| 178 | self.active_flows.add(flow) |
| 179 | |
| 180 | def response(self, flow: http.HTTPFlow): |
| 181 | # websocket flows will receive a websocket_end, |
| 182 | # we don't want to persist them here already |
| 183 | if flow.websocket is None: |
| 184 | self.save_flow(flow) |
| 185 | |
| 186 | def error(self, flow: http.HTTPFlow): |
| 187 | self.response(flow) |