(self)
| 95 | return conn_gen |
| 96 | |
| 97 | def peer_disconnect(self): |
| 98 | # Connection could have already been closed by other end. |
| 99 | NetworkThread.network_event_loop.call_soon_threadsafe(lambda: self._transport and self._transport.abort()) |
| 100 | |
| 101 | # Connection and disconnection methods |
| 102 |
no outgoing calls