model-datastructure/org.modelix.model.lazy/SynchronizedBulkQuery

SynchronizedBulkQuery

class SynchronizedBulkQuery(val nonThreadSafeQuery: IBulkQuery) : IBulkQuery

Constructors

SynchronizedBulkQuery

constructor(nonThreadSafeQuery: IBulkQuery)

Types

inner class Value<E>(val nonThreadSafeValue: IBulkQuery.Value<E>) : IBulkQuery.Value<E>

Properties

nonThreadSafeQuery

val nonThreadSafeQuery: IBulkQuery

Functions

fun IBulkQuery.asSynchronized(): IBulkQuery

open override fun <T> constant(value: T): IBulkQuery.Value<T>

open override fun executeQuery()

open override fun <I, O> flatMap(input: Iterable<I>, f: (I) -> IBulkQuery.Value<O>): IBulkQuery.Value<List<O>>

open override fun offerPrefetch(key: IPrefetchGoal)

open override fun <T : IKVValue> query(hash: KVEntryReference<T>): IBulkQuery.Value<T?>