(
cls,
type: Literal["flows/add", "flows/update"],
f: mitmproxy.flow.Flow,
)
| 438 | |
| 439 | @classmethod |
| 440 | def broadcast_flow( |
| 441 | cls, |
| 442 | type: Literal["flows/add", "flows/update"], |
| 443 | f: mitmproxy.flow.Flow, |
| 444 | ) -> None: |
| 445 | flow_json = flow_to_json(f) |
| 446 | for conn in cls.connections: |
| 447 | conn._broadcast_flow(type, f, flow_json) |
| 448 | |
| 449 | def _broadcast_flow( |
| 450 | self, |