Ksqlite Internal Runtime/ksqlite.internal.runtime.closeable/AtomicCloseableScope

AtomicCloseableScope

open class AtomicCloseableScope : CloseableScope(source)

Thread-safe CloseableScope.

Inheritors

DelegatingAtomicCloseableScope

Constructors

AtomicCloseableScope

constructor()

Properties

override val closed: Boolean

Whether the scope is closed.

Functions

override fun close()

ensureNotClosed

open fun ensureNotClosed(lazyMessage: () -> String = { "Scope is closed" })

Throws IllegalStateException if closed is true.

inline fun <R> notClosed(crossinline lazyMessage: () -> String = { "Scope is closed" }, block: () -> R): R

Returns block's result or throws IllegalStateException if closed is true.

open fun onClose()

Notifies about scope closing.