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

StickyEventStore

class StickyEventStore(stickyEventRepository: StickyEventRepository, tm: RepositoryTransactionManager, contentMappings: EventContentSerializerMappings, config: MatrixClientConfiguration, statisticCollector: ObservableCacheStatisticCollector, storeScope: CoroutineScope, clock: Clock) : Store

Constructors

StickyEventStore

constructor(stickyEventRepository: StickyEventRepository, tm: RepositoryTransactionManager, contentMappings: EventContentSerializerMappings, 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.

deleteByEventId

suspend fun deleteByEventId(roomId: RoomId, eventId: EventId)

suspend fun deleteByRoomId(roomId: RoomId)

suspend fun deleteInvalid()

fun <C : StickyEventContent> get(roomId: RoomId, eventContentClass: KClass<C>): Flow<Map<Pair<UserId, String?>, Flow<StoredStickyEvent<C>?>>>

inline fun <C : StickyEventContent> StickyEventStore.get(roomId: RoomId): Flow<Map<Pair<UserId, String?>, Flow<StoredStickyEvent<C>?>>>

getBySenderAndStickyKey

fun <C : StickyEventContent> getBySenderAndStickyKey(roomId: RoomId, eventContentClass: KClass<C>, sender: UserId, stickyKey: String?): Flow<StoredStickyEvent<C>?>

getBySenderAndStickyKey

inline fun <C : StickyEventContent> StickyEventStore.getBySenderAndStickyKey(roomId: RoomId, sender: UserId, stateKey: String? = null): Flow<StoredStickyEvent<C>?>

open suspend fun init(coroutineScope: CoroutineScope)

suspend fun save(storedStickyEvent: StoredStickyEvent<StickyEventContent>)