Ignore now-closed connections in pool.

1 files changed, 4 insertions, 0 deletions

diff --git a/examples/fetch3.py b/examples/fetch3.py
index bdca3ae..9419afd 100644
--- a/examples/fetch3.py
+++ b/examples/fetch3.py
@@ -34,6 +34,10 @@ class ConnectionPool:
             key = h, p, ssl
             conn = self.connections.get(key)
             if conn:
+                reader, writer = conn
+                if reader._eof:
+                    self.connections.pop(key)
+                    continue
                 if self.verbose:
                     print('* Reusing pooled connection', key, file=sys.stderr)
                 return conn