I will not apologize for art.

.gitignore

@@ -18,3 +18,4 @@ book.tex
 upload.sh
 changes.txt
 *.swp
+testdata*

examples/Python/asyncrrhandlers.py

@@ -171,4 +171,3 @@ def main():
 
 if __name__ == "__main__":
     main()
-

examples/Python/clonecli3_py3.py

@@ -1,4 +1,4 @@
-# coding=utf-8 
+# coding=utf-8
 """
 Clone client Model Three
 Author: Min RK <benjaminrk@gmail.com

examples/Python/clonesrv3_py3.py

@@ -1,4 +1,4 @@
-# coding=utf-8 
+# coding=utf-8
 
 """
 Clone server Model Three

examples/Python/dechat.py

@@ -10,18 +10,18 @@
 
 def listen(masked):
     """listen for messages
-    
+
     masked is the first three parts of an IP address:
-    
+
         192.168.1
-    
+
     The socket will connect to all of X.Y.Z.{1-254}.
     """
     ctx = zmq.Context.instance()
     listener = ctx.socket(zmq.SUB)
     for last in range(1, 255):
         listener.connect("tcp://{0}.{1}:9000".format(masked, last))
-    
+
     listener.setsockopt(zmq.SUBSCRIBE, b'')
     while True:
         try:
@@ -42,12 +42,12 @@ def main():
     inet = ifaddresses(args.interface)[AF_INET]
     addr = inet[0]['addr']
     masked = addr.rsplit('.', 1)[0]
-    
+
     ctx = zmq.Context.instance()
-    
+
     listen_thread = Thread(target=listen, args=(masked,))
     listen_thread.start()
-    
+
     bcast = ctx.socket(zmq.PUB)
     bcast.bind("tcp://%s:9000" % args.interface)
     print("starting chat on %s:9000 (%s.*)" % (args.interface, masked))
@@ -62,4 +62,3 @@ def main():
 
 if __name__ == '__main__':
     main()
-

examples/Python/eagain.py

@@ -8,15 +8,15 @@ def main():
     mailbox.sndhwm = 4
     mailbox.sndtimeo = 0
     mailbox.connect("tcp://localhost:9876")
-    
+
     for count in range(10):
         print("Sending message %i" % count)
         try:
             mailbox.send(b"message %i" % count)
         except zmq.Again as e:
             print(e)
             break
-    
+
     ctx.destroy(linger=0)
 
 if __name__ == '__main__':

examples/Python/interface.py

@@ -143,4 +143,3 @@ def reap_peers(self):
                 print("reaping %s" % peer.uuid, peer.expires_at, now)
                 self.peers.pop(peer.uuid)
                 self.pipe.send_multipart([b'LEFT', peer.uuid])
-

examples/Python/interrupt.py

@@ -18,4 +18,3 @@
     # clean up
     socket.close()
     context.term()
-

examples/Python/kvmsg.py

@@ -70,7 +70,7 @@ def get(self, k, default=None):
         return self.properties.get(k, default)
 
     def store(self, dikt):
-        """Store me in a dict if I have anything to store 
+        """Store me in a dict if I have anything to store
         else delete me from the dict."""
         if self.key is not None and self.body is not None:
             dikt[self.key] = self
@@ -99,15 +99,15 @@ def from_msg(cls, msg):
         body = body if body else None
         prop = decode_properties(prop_s)
         return cls(seq, uuid=uuid, key=key, properties=prop, body=body)
-    
+
     def __repr__(self):
         if self.body is None:
             size = 0
             data=b'NULL'
         else:
             size = len(self.body)
             data = repr(self.body)
-        
+
         mstr = "[seq:{seq}][key:{key}][size:{size}][props:{props}][data:{data}]".format(
             seq=self.sequence,
             # uuid=hexlify(self.uuid),
@@ -117,8 +117,8 @@ def __repr__(self):
             data=data,
         )
         return mstr
-        
-    
+
+
     def dump(self):
         print("<<", str(self), ">>", file=sys.stderr)
 # ---------------------------------------------------------------------

examples/Python/peering2.py

@@ -88,8 +88,8 @@ def main(myself, peers):
     for peer in peers:
         tprint("I: connecting to cloud frontend at %s" % peer)
         cloudbe.connect("ipc://%s-cloud.ipc" % peer)
-    
-    
+
+
     if not isinstance(peers[0], bytes):
         peers = [peer.encode('ascii') for peer in peers]
 

examples/Python/rtreq.py

@@ -51,7 +51,7 @@ def worker_thread(context=None):
 for _ in range(NBR_WORKERS * 10):
     # LRU worker is next waiting in the queue
     address, empty, ready = client.recv_multipart()
-    
+
     client.send_multipart([
         address,
         b'',
@@ -66,4 +66,3 @@ def worker_thread(context=None):
         b'',
         b'END',
     ])
-

examples/Python/udplib.py

@@ -38,4 +38,3 @@ def recv(self, n):
         if addrinfo[0] != self.address:
             print("Found peer %s:%d" % addrinfo)
         return buf
-

examples/Python/udpping3.py

@@ -15,4 +15,4 @@ def main():
     interface.stop()
 
 if __name__ == '__main__':
-    main()
+    main()