MOD: Attempt to write EOF on terminate

Author: nmacholl

CHANGELOG.md

@@ -1,9 +1,10 @@
 # Changelog
 
-### 0.49.0 - TBD
+## 0.49.0 - TBD
 
-##### Enhancements
+#### Enhancements
 - Added a `keep_zip` parameter to `Historical.batch.download()`. When `True`, and downloading all files, the jobs contents will be saved as a ZIP file
+- Calling `Live.terminate()` will now attempt to write EOF before aborting the connection to help close the remote end
 
 ## 0.48.0 - 2025-01-21
 

databento/live/session.py

@@ -510,10 +510,13 @@ def subscribe(
             )
 
     def terminate(self) -> None:
-        if self._transport is None:
-            return
-        self._transport.abort()
-        self._cleanup()
+        with self._lock:
+            if self._transport is None:
+                return
+            if self._transport.can_write_eof():
+                self._transport.write_eof()
+            self._transport.abort()
+            self._cleanup()
 
     async def wait_for_close(self) -> None:
         """