Fixed mistake in commit 3a19d65.

pika · May 28, 2013 · 0bfd670 · 0bfd670
1 parent da04bc0
commit 0bfd670
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pika/adapters/base_connection.py b/pika/adapters/base_connection.py
@@ -333,7 +333,7 @@ def _handle_write(self):
             frame = self.outbound_buffer.popleft()
             try:
                 while total_written < len(frame):
-                    total_written += self.socket.send(frame)
+                    total_written += self.socket.send(frame[total_written:])
             except socket.timeout:
                 raise
             except socket.error, error: