ConnectionDAOImpl

Constructors

constructor(connectionsQueries: ConnectionsQueries, conversationsQueries: ConversationsQueries, readDispatcher: ReadDispatcher, writeDispatcher: WriteDispatcher)

open suspend override fun getConnection(conversationId: QualifiedIDEntity): ConnectionEntity?

open override fun getConnections(): Flow<List<ConnectionEntity>>

open suspend override fun insertConnection(connectionEntity: ConnectionEntity)

open suspend override fun insertConnections(users: List<ConnectionEntity>)

open suspend override fun setAllConnectionsAsNotified()

open suspend override fun updateConnectionLastUpdatedTime(lastUpdate: String, id: String)

open suspend override fun updateNotificationFlag(flag: Boolean, userId: QualifiedIDEntity)