

def is_connected_to(self, peer_id):
    return (self.endpoint.is_connected() and (self.endpoint.get_peer()[1] == peer_id))

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/actor/actorport.py InPort.is_connected_to/original