In attempting to integrate both zmq and a Pyforms GUI, I am faced with the challenge of each requiring its own event loop. The goal is to create a Pyforms GUI with a text field that can display incoming zmq messages. Below is the simplified code that I am working on:
import pyforms
from pyforms import BaseWidget
from pyforms.controls import ControlTextArea
from pyforms.controls import ControlButton
import threading
import zmq
from zmq.asyncio import Context
from zmq.eventloop.zmqstream import ZMQStream
from zmq.eventloop import ioloop
class SimpleExample1(BaseWidget):
def __init__(self):
super(SimpleExample1,self).__init__('Simple example 1')
#Definition of the forms fields
self._controltextarea = ControlTextArea('textarea to show incoming zmq messages')
self._button = ControlButton('Press this button')
def echo(msg):
self._controltextarea.__add__(msg)
context = Context.instance()
s = context.socket(zmq.PULL)
s.connect('tcp://127.0.0.1:5014')
stream = ZMQStream(s)
stream.on_recv(echo)
#Execute the application
if __name__ == "__main__":
guiThread = threading.Thread(target=pyforms.start_app( SimpleExample1 ))
zmqThread = threading.Thread(target=lambda: ioloop.IOLoop.current().start())
zmqThread.setDaemon(True)
guiThread.start()
zmqThread.start()
This is the ZMQ sender.
import zmq
import time
context = zmq.Context()
publisher = context.socket(zmq.PUSH)
publisher.bind('tcp://127.0.0.1:5014')
while True:
publisher.send_string('something')
time.sleep(1)
Exploring possible solutions, one involves using threads as in the provided code. However, combining both event loops has proven challenging so far. Another approach could be integrating the zmq function call "echo()" into the Pyforms' event loop based on QT. This method might offer a more elegant solution, but the implementation remains uncertain.
While experimenting with these solutions, resources like pyzmq readthedocs, zeromq org, and pyforms readthedocs have been invaluable. Despite delving into concepts such as futures, promises, coroutines, asyncio, and green in Python, successfully achieving a simple function call for "echo" upon message receipt remains elusive.
If you have any insights or suggestions on how to make this setup work seamlessly, I would greatly appreciate it.