-
Notifications
You must be signed in to change notification settings - Fork 56
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
no wait bytes with asyncio.wait_for for each frame #157
Conversation
@@ -137,10 +137,8 @@ async def close( | |||
if self.is_closed: | |||
return None | |||
|
|||
await asyncio.wait_for( | |||
self.loop.create_task(self.__closer(exc)), |
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.
Here should not have been task and await asyncio.wait_for(self.__closer(exc), timeout)
was enough, am I right?
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.
Now it's doesn't matter
d1158de
to
784dda9
Compare
@dgoeries could you make sure that the code from this branch fixes this monstrous performance drop? |
@mosquito this fixes most of it thanks!. With this PR i have around 5.9-6kHz message consumption. |
I ran again. Now i barely see a difference, must have had a bad period when comparing. |
Yeah, it seems that the 3.3.1 version is slightly more performing (~5%) in message consumption. |
fixes #156