New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Refactor waiter handling in channel #83
Conversation
Are you using the no_wait argument with aioamqp ? |
beware of the typo |
I am not using no_wait, it was just the visual noise in the code (and the open issue) prompting a friday afternoon tidy. |
Happy to know we have a few tests ;) |
8d85769
to
1706350
Compare
I was leaning on them for this, they did their job, let's see if that fix makes things any better. |
Seems fine now, fixed the typo whilst at it. |
@@ -188,21 +188,32 @@ def server_channel_close(self, frame): | |||
self.connection_closed(results['reply_code'], results['reply_text']) | |||
|
|||
@asyncio.coroutine | |||
def _write_frame_awaiting_response( | |||
self, waiter_id, frame, request, no_wait, **kwargs): |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This indentation seems really odd. Since there are lines with lenght longer than 80, we should keep this code style
I believe this is ready now. |
Yes, squash both commits and I'll merge it |
06f6add
to
ac3dc1f
Compare
They're squashed. |
It's merged since yesterday. |
Rough pass at tidying up waiter handling.