CoroutineObjectRepository

class CoroutineObjectRepository<T : Any> constructor(val synchronous: ObjectRepository<T>, val type: KType, documentFormat: NitriteDocumentFormat, dispatcher: CoroutineDispatcher = Dispatchers.IO) : CoroutineWrapper

Constructors

constructor(synchronous: ObjectRepository<T>, type: KType, documentFormat: NitriteDocumentFormat, dispatcher: CoroutineDispatcher = Dispatchers.IO)

data class Change<T>(val changeType: ChangeType, val changedItems: Flow<T>)

data class Item<T>(val changeTimestamp: Instant, val changeType: ChangeType, val item: T)

val synchronous: ObjectRepository<T>

suspend fun createIndex(indexOptions: IndexOptions, path: DocumentPathBuilder)

suspend fun createIndex(indexOptions: IndexOptions, path: KProperty<*>)

suspend fun <T> dispatch(action: suspend CoroutineScope.() -> T): T

suspend fun find(filter: ObjectFilter? = null, findOptions: FindOptions? = null): Flow<T>

suspend fun findById(id: Int): T?

suspend fun findById(id: Long): T?

suspend fun insert(items: Array<T>): WriteResult

inline suspend fun <T : Any> CoroutineObjectRepository<T>.insert(item: T): WriteResult

inline suspend fun <T : Any> CoroutineObjectRepository<T>.insert(items: Collection<T>): WriteResult

suspend fun remove(element: T): WriteResult

suspend fun remove(filter: ObjectFilter, removeOptions: RemoveOptions? = null): WriteResult

suspend fun removeAll(): WriteResult

suspend fun update(filter: ObjectFilter, update: T, upsert: Boolean = false): WriteResult