trixnity-client/de.connect2x.trixnity.client.store/RoomOutboxMessageStore

RoomOutboxMessageStore

class RoomOutboxMessageStore(roomOutboxMessageRepository: RoomOutboxMessageRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

RoomOutboxMessageStore

constructor(roomOutboxMessageRepository: RoomOutboxMessageRepository, tm: RepositoryTransactionManager, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock)

Functions

open suspend override fun clearCache()

Only deletes everything, that can be fetched from server.

open suspend override fun deleteAll()

Deletes everything.

suspend fun deleteByRoomId(roomId: RoomId)

fun get(roomId: RoomId, transactionId: String): Flow<RoomOutboxMessage<*>?>

fun getAll(): Flow<Map<RoomOutboxMessageRepositoryKey, Flow<RoomOutboxMessage<*>?>>>

fun getAsFlow(roomId: RoomId, transactionId: String): Flow<RoomOutboxMessage<*>?>

open suspend fun init(coroutineScope: CoroutineScope)

suspend fun update(roomId: RoomId, transactionId: String, updater: suspend (RoomOutboxMessage<*>?) -> RoomOutboxMessage<*>?)