Skip to content
This repository has been archived by the owner on Feb 21, 2023. It is now read-only.

#464 Make pipeline sending all commands in a single step #467

Closed

Conversation

paul-nameless
Copy link

Patch for describing problem in #464 issue

@@ -273,6 +273,32 @@ def _process_pubsub(self, obj, *, process_waiters=True):
else:
logger.warning("Unknown pubsub message received %r", obj)

def execute_pipeline(self, pipeline_cmds, encoding=_NOTSET):
cmds = []

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

You should probably use bytearray here. List joining was what asyncio StreamWriter used to do as well, then they found that bytearray was more efficient. This is what bytearray was designed for, actually...

@popravich
Copy link
Contributor

I'm sorry, but I'm closing this PR in favour of #473.
Adding another way to send commands is bad idea, execute method has lots of logic
which isn't repeated in execute_pipeline.

@popravich popravich closed this Oct 10, 2018
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants