Package-level declarations

A GenericMonitor implementation backed by an atomic boolean value.

A coroutine-based waiter that suspends until a boolean value satisfies a condition.

A ConditionalValue specialized for boolean values, providing waitUntilTrue and waitUntilFalse convenience methods.

A coroutine-based conditional waiter backed by MutableStateFlow.

Abstract base class that wraps Guava's AbstractExecutionThreadService with Kotlin Duration-based synchronous start and stop methods.

Abstract base class that wraps Guava's AbstractIdleService with Kotlin Duration-based synchronous start and stop methods.

Abstract base class providing thread-blocking wait methods backed by a Guava Monitor.

Abstract coroutine-based waiter that suspends callers until a per-call condition is satisfied.

A function type used as a callback during timed monitor waits.

A CountDownLatch that logs a message on each wait timeout and retries until the latch reaches zero.

Whether this CountDownLatch has reached zero.

Waits for the CountDownLatch to reach zero, or for the specified duration to elapse.

Executes block and calls CountDownLatch.countDown in a finally block, ensuring the latch is decremented even if the block throws.

Creates a Service.Listener for this Service that logs all lifecycle transitions (starting, running, stopping, terminated, failed) using the provided logger.

Creates a new thread that automatically counts down the given latch when block completes.

Acquires a permit from this Semaphore, executes block, and releases the permit in a finally block.