die printfs

coolamqp/uplink/handshake.py

@@ -22,7 +22,7 @@ CLIENT_DATA = [
         # because RabbitMQ is some kind of a fascist and does not allow
         # these fields to be of type short-string
         (b'product', (b'CoolAMQP', 'S')),
-        (b'version', (b'0.85', 'S')),
+        (b'version', (b'0.86', 'S')),
         (b'copyright', (b'Copyright (C) 2016-2017 DMS Serwis', 'S')),
         (b'information', (b'Licensed under the MIT License.\nSee https://github.com/smok-serwis/coolamqp for details', 'S')),
         (b'capabilities', ([(capa, (True, 't')) for capa in SUPPORTED_EXTENSIONS], 'F')),

coolamqp/uplink/listener/epoll_listener.py

@@ -87,9 +87,9 @@ class EpollListener(object):
 
                 if event & select.EPOLLOUT:
 
-                    if sock.on_write():
-                        # I'm done with sending for now
-                        assert len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0
+                    sock.on_write()
+                    # I'm done with sending for now
+                    if len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0:
                         self.epoll.modify(sock.fileno(), RO)
 
             except SocketFailed:

setup.py

@@ -4,12 +4,12 @@ from setuptools import setup
 
 
 setup(name=u'CoolAMQP',
-      version='0.85',
+      version='0.86',
       description=u'The fastest AMQP client',
       author=u'DMS Serwis s.c.',
       author_email=u'piotrm@smok.co',
       url=u'https://github.com/smok-serwis/coolamqp',
-      download_url='https://github.com/smok-serwis/coolamqp/archive/v0.85.zip',
+      download_url='https://github.com/smok-serwis/coolamqp/archive/v0.86.zip',
       keywords=['amqp', 'rabbitmq', 'client', 'network', 'ha', 'high availability'],
       packages=[
           'coolamqp',