[Zodb-checkins] CVS: ZODB3/ZEO/zrpc - connection.py:1.47

[Jeremy Hylton]

Update of /cvs-repository/ZODB3/ZEO/zrpc
In directory cvs.zope.org:/tmp/cvs-serv7400

Modified Files:
	connection.py 
Log Message:
Add flush method.


=== ZODB3/ZEO/zrpc/connection.py 1.46 => 1.47 ===
--- ZODB3/ZEO/zrpc/connection.py:1.46	Tue Apr 22 15:14:21 2003
+++ ZODB3/ZEO/zrpc/connection.py	Thu Apr 24 18:04:27 2003
@@ -451,6 +451,13 @@
         finally:
             self.replies_cond.release()
 
+    def flush(self):
+        """Invoke poll() until the output buffer is empty."""
+        if __debug__:
+            self.log("flush")
+        while self.writable():
+            self.poll()
+
     def poll(self):
         """Invoke asyncore mainloop to get pending message out."""
         if __debug__: