EventQueue

@Singleton
class EventQueue<T> @Inject constructor : SharedEvent<T>

(See this).

Constructors

Link copied to clipboard
@Inject
constructor()

Functions

Link copied to clipboard
open override fun getFor(consumerId: String): Flow<T>
Link copied to clipboard
suspend fun push(event: T)