commit 51ba56c31b5a49c7d4fd24d3e30ce2b9d8579d17
author James Broadhead <jbroadhead@twitter.com> Sun Aug 10 22:03:38 2014 +0100
committer Roger Meier <roger@apache.org> Sun Sep 28 22:39:55 2014 +0200
tree e0f063eb72e2ec71f01ff910c3b32fc20342f83d
parent b360b65d3f5841938361f64c1265d3dddc66d281

py.twisted: Avoid synchronous exceptions

This is an update of the patch posted to:
https://issues.apache.org/jira/browse/THRIFT-585
and a re-write of 8345772

Patch: Mattias de Zalenski, James Broadhead

Jira: THRIFT-585

lib/py/src/transport/TTwisted.py

diff --git a/lib/py/src/transport/TTwisted.py b/lib/py/src/transport/TTwisted.py
index 2b77414..29bbd4c 100644
--- a/lib/py/src/transport/TTwisted.py
+++ b/lib/py/src/transport/TTwisted.py
@@ -42,7 +42,7 @@
     def flush(self):
         msg = self.__wbuf.getvalue()
         self.__wbuf = StringIO()
-        self.sendMessage(msg)
+        return self.sendMessage(msg)
 
     def sendMessage(self, message):
         raise NotImplementedError
@@ -55,7 +55,7 @@
         self.func = func
 
     def sendMessage(self, message):
-        self.func(message)
+        return self.func(message)
 
 
 class ThriftClientProtocol(basic.Int32StringReceiver):