async def disconnect_peer(self, peer_id: ID) -> None:
    if (peer_id in self.handshaked_peers):
        self.logger.debug('Disconnect from %s', peer_id)
        self.handshaked_peers.remove(peer_id)
        (await self.host.disconnect(peer_id))
    else:
        self.logger.debug('Already disconnected from %s', peer_id)
async def disconnect_peer(self, peer_id: ID) -> None:
    if (peer_id in self.handshaked_peers):
        self.logger.debug('Disconnect from %s', peer_id)
        self.handshaked_peers.remove(peer_id)
        (await self.host.disconnect(peer_id))
    else:
        self.logger.debug('Already disconnected from %s', peer_id)