9
1
mirror of https://github.com/QuantumPackage/qp2.git synced 2024-11-18 11:23:38 +01:00
qp2/ocaml/tests/test_pub.py

16 lines
280 B
Python
Executable File

#!/usr/bin/env python3
import zmq
import sys, os
def main():
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://127.0.0.1:41280")
socket.setsockopt(zmq.SUBSCRIBE, "")
while True:
print socket.recv()
if __name__ == '__main__':
main()