def peer_disconnect(self):
    NetworkThread.network_event_loop.call_soon_threadsafe((lambda : (self._transport and self._transport.abort())))
def peer_disconnect(self):
    NetworkThread.network_event_loop.call_soon_threadsafe((lambda : (self._transport and self._transport.abort())))