…ynchronously Adds ability of channels to act synchronously on top of an asynchronous transport Adds ability to enforce a synchronous connection handshake on an asynchronous transport Catch `EINTR` in a read loop, raise all other read exceptions to fix #44 Immediately closes a connection and raises ConnectionClosed if there is a frame error when reading from the broker Immediately closes a connection and raises ConnectionClosed if user tries to send a frame that is larger than negotiated frame max Adds Connection.closed property
handler. Fix several tests
synchronous transport. Solves #31
handle when `Channel.channel` has been cleared so that exception can be properly raised. Fixes #22.
…foundation for broker-specific features Truncate reply_text when sending channel.close to the broker Fixed bug in Channel.clear_synchronous_cb which needs to always return not-None
…with gevent.GreenletExit and SystemExit
…nnel. Resolves issues with accessing this information in a close callback handler or anytime thereafter.
Fixed failure to re-use past-closed channel ids
…. Removed ugly hack put in place for lookahead and in general localized content frame handling to where it belongs in BasicClass. [#110] [#112 state:resolved] Use deque in Frame.read_frames()
Fixed a heretofore unseen but nasty bug in frame ordering when requeing incomplete content Fixed Reader.__str__ so it doesn't print the universe
…red frames per Channel [#110] Added --time parameter to stress test
Much improved error handling on Channel._process_frames [#82 state:resolved]
… the connection and channel close handling [#100] Fixed sending of close_ok in ChannelClass._recv_close Preparing 0.1.5
Some simple exception handling if Channel.dispatch fails Added ticket=None where missing in QueueClass Connection tracks number of frames read and written, stress_test reports it