`Subscribe` and `Pull` in ZMAG

These examples demonstrate how to use the Frontend class in ZMAG for subscribing to channels and pulling work from a server.

from zmag import Frontend

client = Frontend(
    host="tcp://127.0.0.1:5555",
    mode="queue",
    is_sync=False,  
)

The subscribe method is used to listen for messages from specific channels.

Subscribing with an empty string ("") listens to messages from all channels.

while True:
    message = await client.subscribe("")
    print("Received:", message)

To limit the subscription to a particular channel, pass the channel name as an argument.

while True:
    message = await client.subscribe("the_channel")
    print("Received:", message)

Pull

The pull method is used to receive work from a push-pull pattern (also known as task distribution).

while True:
    work = await client.pull()
    print("Received:", work)