

def __init__(self, masterip, port):
    self.caserun = {
        
    }
    self.context = zmq.Context.instance()
    self.results_sender = self.context.socket(zmq.PUSH)
    self.sport = str((int(port) + 1))
    self.results_sender.connect(('tcp://%s:%s' % (masterip, self.sport)))

dataset/ETHPy150Open idumpling/robotx/robotx/core/distlistener.py MultiListener.__init__/original