Merge remote-tracking branch 'upstream/main' into improving-ci-coverage-and-configuring-.coveragerc

Author: leseb

src/ogx/core/library_client.py

@@ -323,7 +323,12 @@ async def _consume() -> None:
                         await asyncio.sleep(0.01)
             finally:
                 if async_gen is not None:
-                    await async_gen.aclose()
+                    if hasattr(async_gen, "aclose"):
+                        await async_gen.aclose()
+                    elif hasattr(async_gen, "close"):
+                        close = async_gen.close()
+                        if asyncio.iscoroutine(close):
+                            await close
 
         future = asyncio.run_coroutine_threadsafe(_consume(), self.loop)