Hi
I’m trying to write a device server where I want to have a zmq socket listening on port.
The zmq context is initialised with this code:
async def setup_zmq(self):
self.context = zmq.Context()
self.receiver = self.context.socket(zmq.PULL)
self.receiver.connect("tcp://10.42.41.10:9999")
print("receiver set up")
return 0
Now I want to run a function like this without blocking the detector:
async def run_zmq(self):
while (True):
print('ZMQ receiving started')
message_parts = self.receiver.recv_multipart(copy = False)
print('Message received')
I tried some things with asyncio, but I’m not able to start this without blocking the server. Is something like this possible? If so, then how?