modulecheck-utils:lazy/modulecheck.utils.lazy.internal/LazySetImpl

LazySetImpl

internal class LazySetImpl<E>(cache: Set<E>, sources: List<LazySet.DataSource<E>>) : AbstractFlow<E> , LazySet<E>

Constructors

fun <E> LazySetImpl(cache: Set<E>, sources: List<LazySet.DataSource<E>>)

Functions

suspend override fun collect(collector: FlowCollector<E>)

open suspend override fun collectSafely(collector: FlowCollector<E>)

open suspend override fun contains(element: Any?): Boolean

open suspend override fun isEmpty(): Boolean

open suspend override fun isNotEmpty(): Boolean

private fun LazySet.State<E>.remainingFlow(): Flow<Set<E>>

open override fun snapshot(): LazySet.State<E>

private fun updateCache(new: Set<E>, completed: List<LazySet.DataSource<E>>)

Properties

open override val isFullyCached: Boolean

internal val state: AtomicReference<LazySet.State<E>>

Sources