(source)
| 398 | source_loop.call_soon_threadsafe(source.cancel) |
| 399 | |
| 400 | def _call_set_state(source): |
| 401 | if (destination.cancelled() and |
| 402 | dest_loop is not None and dest_loop.is_closed()): |
| 403 | return |
| 404 | if dest_loop is None or dest_loop is source_loop: |
| 405 | _set_state(destination, source) |
| 406 | else: |
| 407 | if dest_loop.is_closed(): |
| 408 | return |
| 409 | dest_loop.call_soon_threadsafe(_set_state, destination, source) |
| 410 | |
| 411 | destination.add_done_callback(_call_check_cancel) |
| 412 | source.add_done_callback(_call_set_state) |
nothing calls this directly
no test coverage detected