do not create sender at close

fluent · Jun 5, 2024 · b92d5f1 · b92d5f1
1 parent 1e58a7e
commit b92d5f1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 17 deletions.
diff --git a/fluent/asynchandler.py b/fluent/asynchandler.py
@@ -8,19 +8,3 @@ class FluentHandler(handler.FluentHandler):
 
     def getSenderClass(self):
         return asyncsender.FluentSender
-
-    def close(self):
-        self.acquire()
-        try:
-            try:
-                self.sender.close()
-            finally:
-                super().close()
-        finally:
-            self.release()
-
-    def __enter__(self):
-        return self
-
-    def __exit__(self, exc_type, exc_val, exc_tb):
-        self.close()
diff --git a/fluent/handler.py b/fluent/handler.py
@@ -264,7 +264,10 @@ def close(self):
         self.acquire()
         try:
             try:
-                self.sender.close()
+                s = self._sender
+                self._sender = None
+                if s is not None:
+                    s.close()
             finally:
                 super().close()
         finally: