TypingIndicatorIncomingRepositoryImpl

internal class TypingIndicatorIncomingRepositoryImpl(userTypingCache: ConcurrentMutableMap<ConversationId, MutableSet<UserId>>, userPropertyRepository: UserPropertyRepository) : TypingIndicatorIncomingRepository

Constructors

Link copied to clipboard
constructor(userTypingCache: ConcurrentMutableMap<ConversationId, MutableSet<UserId>>, userPropertyRepository: UserPropertyRepository)

Types

Link copied to clipboard
object Companion

Functions

Link copied to clipboard
open suspend override fun addTypingUserInConversation(conversationId: ConversationId, userId: UserId)
Link copied to clipboard
open suspend override fun clearExpiredTypingIndicators()
Link copied to clipboard
open suspend override fun observeUsersTyping(conversationId: ConversationId): Flow<Set<UserId>>
Link copied to clipboard
open suspend override fun removeTypingUserInConversation(conversationId: ConversationId, userId: UserId)