Commit 8f1e9065 authored by Dom Sekotill's avatar Dom Sekotill
Browse files

Rename Broadcast.aclose() to Broadcast.shutdown_hook()

parent 2aca37a7

kilter/service/runner.py

+1 −1
Original line number Diff line number Diff line
@@ -58,7 +58,7 @@ class _Broadcast(Broadcast[EventMessage]): 
		super().__init__()

		self._ready = anyio.Condition()



	async def aclose(self) -> None:

	async def shutdown_hook(self) -> None:

		async with self._ready:

			self._ready.notify_all()

kilter/service/session.py

+1 −1
Original line number Diff line number Diff line
@@ -243,7 +243,7 @@ class Session: 
	async def __aexit__(self, *_: object) -> None:

		await self._broadcast.__aexit__(None, None, None)

		# on session close, wake up any remaining deliver() awaitables

		await self._broadcast.aclose()

		await self._broadcast.shutdown_hook()



	async def deliver(self, message: EventMessage) -> type[Continue]|type[Skip]:

		"""

kilter/service/util.py

+1 −1
Original line number Diff line number Diff line
@@ -44,7 +44,7 @@ class Broadcast(anyio.Condition, Generic[T]): 
		A hook for subclasses to inject synchronisation instructions after sending objects

		"""  # noqa: D401



	async def aclose(self) -> None:

	async def shutdown_hook(self) -> None:

		"""

		A hook for subclasses to inject cleanup or synchronisation instructions on close