Add working pyzmq socket support

Author: Joel 'Aaron' Cohen

pub.py

@@ -0,0 +1,22 @@
+# publisher
+
+import trzmq
+import trio
+import zmq
+
+async def run():
+    context = zmq.Context()
+    socket = context.socket(zmq.PUB)
+    socket.connect("tcp://0.0.0.0:5556")
+
+    s = trzmq.Socket(socket)
+    i = 1
+    while True:
+        topic = b"ZMQ-Test"
+        message = "Hello, NORM " + str(i) + "..."
+        await s.send(b"%b %b" % (topic, message.encode()))
+        print("%s %s" % (topic, message))
+        i += 1
+        await trio.sleep(1)
+
+trio.run(run)

requirements.txt

@@ -0,0 +1,2 @@
+pyzmq
+trio

sub.py

@@ -0,0 +1,17 @@
+# subscriber
+
+import trio
+import trzmq
+import zmq
+
+async def run():
+    context = zmq.Context()
+    socket = context.socket(zmq.SUB)
+    socket.bind("tcp://0.0.0.0:5556")
+    socket.setsockopt_string(zmq.SUBSCRIBE, '')
+    s = trzmq.Socket(socket)
+    while True:
+        string = await s.recv()
+        print(string)
+
+trio.run(run)

trzmq/__init__.py

@@ -5,3 +5,6 @@
 
 from ._proxy import *
 __all__ += _proxy.__all__
+
+from ._socket import *
+__all__ += _socket.__all__