* Block as expected on start, even if already started. * Raise runtime error if starting the reader without a message handler. * Add on_close signal to the reader. * Allow upgrading to tls+snappy or tls+deflate.
0.1.2
~~~~~~~~~~~~~~~~~~
* Flush delfate buffer for each message.
0.1.1
~~~~~~~~~~~~~~~~~~
* Fix packaging stream submodule. * Send queued messages before closing socket. * Continue to read from socket on EAGAIN