Write all data after paired stream closed.

2013-02-28 11:05:14 +08:00 · 2013-02-28 11:05:14 +08:00 · 543d6db55a
commit 543d6db55a
parent add7a122ac
1 changed files with 4 additions and 1 deletions
--- a/server.py
+++ b/server.py
@ -66,7 +66,10 @@ class PairedStream(iostream.IOStream):
    def on_close(self):
        remote = getattr(self, "remote")
        if isinstance(remote, PairedStream) and not remote.closed():
-            remote.close()
+            if remote.writing():
+                remote.write("", callback=remote.close())
+            else:
+                remote.close()


 class ConnHandler(PairedStream):