Skip to content
Snippets Groups Projects
Commit eb866811 authored by Jelle Aalbers's avatar Jelle Aalbers
Browse files

Fix loop condition

parent b57ad443
No related branches found
No related tags found
No related merge requests found
Loading
Loading
@@ -473,7 +473,7 @@ class Channel(base.AMQPChannel):
body_length_received = 0
body_total_size = header_value.body_size
 
while len(body_value) < body_total_size:
while body_length_received < body_total_size:
body_part = self._wait_on_frame(CONTENT_BODY)
 
self._check_for_rpc_request(body_part)
Loading
Loading
@@ -497,9 +497,6 @@ class Channel(base.AMQPChannel):
else:
body_chunks.append(body_part.value)
 
if body_length_received == body_total_size:
break
if not PYTHON3:
body_value = ''.join(body_chunks)
 
Loading
Loading
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment