/** * Waits for the queue to be shut down. * * @tsplus getter effect/core/stm/THub/TDequeue awaitShutdown */ export function awaitShutdown(self: THub.TDequeue): STM { return self.isShutdown.flatMap((isShutdown) => isShutdown ? STM.unit : STM.retry) }