Permalink
Browse files

Quick'n'dirty backport of flush_outbound() for AsyncoreConnection only.

  • Loading branch information...
1 parent 20d3307 commit b1d1cbfb655a062ced423268bf5433a9222d7ba5 @tonyg tonyg committed Jul 14, 2011
Showing with 4 additions and 0 deletions.
  1. +4 −0 pika/asyncore_adapter.py
View
@@ -106,6 +106,10 @@ def disconnect_transport(self):
if self.dispatcher:
self.dispatcher.close()
+ def flush_outbound(self):
+ while self.outbound_buffer:
+ self.drain_events()
+
def drain_events(self):
loop(count = 1)

0 comments on commit b1d1cbf

Please sign in to comment.