Intercept this Flow. Processing will stop until resume is called.
(self)
| 242 | self.live = False |
| 243 | |
| 244 | def intercept(self): |
| 245 | """ |
| 246 | Intercept this Flow. Processing will stop until resume is |
| 247 | called. |
| 248 | """ |
| 249 | if self.intercepted: |
| 250 | return |
| 251 | self.intercepted = True |
| 252 | if self._resume_event is not None: |
| 253 | self._resume_event.clear() |
| 254 | |
| 255 | async def wait_for_resume(self): |
| 256 | """ |