update pub-sub example

pub-sub/publisher.py

@@ -9,7 +9,10 @@ context = zmq.Context()
 socket = context.socket(zmq.PUB)
 socket.bind('tcp://*:5555')
 
-for i in range(5):
-    socket.send(b'status 5')
+for i in range(5000):
+    # socket.send(b'status 5')
+    # socket.send(b'statuses')
+    s = f'status {i}'
+    socket.send(s.encode('ascii'))
     socket.send(b'All is well')
     time.sleep(1)

pub-sub/subscriber.py

@@ -9,6 +9,7 @@ context = zmq.Context()
 socket = context.socket(zmq.SUB)
 socket.connect('tcp://localhost:5555')
 socket.setsockopt(zmq.SUBSCRIBE, b'status')
+# socket.setsockopt(zmq.SUBSCRIBE, b'')
 
 while True:
     message = socket.recv_multipart()