nicegui/examples/zeromq/zmq-server.py

#!/usr/bin/env python3
import asyncio
import random

import zmq
import zmq.asyncio

context = zmq.asyncio.Context()
socket = context.socket(zmq.PUSH)
socket.bind('tcp://localhost:5555')


async def send_loop():
    while True:
        number = random.randint(0, 100)
        print(f'Sending number {number}')
        await socket.send(str(number).encode('ascii'))
        await asyncio.sleep(0.1)


asyncio.run(send_loop())