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> (source)

Constructors

Link copied to clipboard
constructor(cache: Set<E>, sources: List<LazySet.DataSource<E>>)

Properties

Link copied to clipboard
open override val isFullyCached: Boolean
Link copied to clipboard

Functions

Link copied to clipboard
fun <E> Flow<E>.asDataSource(priority: LazySet.DataSource.Priority = MEDIUM): LazySet.DataSource<E>
Link copied to clipboard
suspend override fun collect(collector: FlowCollector<E>)
Link copied to clipboard
open suspend override fun collectSafely(collector: FlowCollector<E>)
Link copied to clipboard
open suspend override fun contains(element: Any?): Boolean
Link copied to clipboard
open suspend override fun containsAny(other: LazySet<Any?>): Boolean
Link copied to clipboard
suspend fun <T : B, E : B, B> LazySet<T>.containsAny(elements: Collection<E>): Boolean
Link copied to clipboard
inline suspend fun <T : E, E> LazySet<E>.getOrNull(element: E): T?
Link copied to clipboard
open suspend override fun isEmpty(): Boolean
Link copied to clipboard
open suspend override fun isNotEmpty(): Boolean
Link copied to clipboard
private fun LazySet.State<E>.remainingFlow(): Flow<Set<E>>
Link copied to clipboard
open override fun snapshot(): LazySet.State<E>
Link copied to clipboard
fun <E> Flow<E>.toLazySet(priority: LazySet.DataSource.Priority = MEDIUM): LazySet<E>
Link copied to clipboard
private fun updateCache(new: Set<E>, completed: List<LazySet.DataSource<E>>)