trixnity-core/de.connect2x.trixnity.core/ClientEventEmitter

ClientEventEmitter

interface ClientEventEmitter<T : List<ClientEvent<*>>>

Inheritors

ClientEventEmitterImpl

Types

Priority

object Priority

Functions

emit

abstract suspend fun emit(events: T)

abstract fun subscribe(priority: Int = Priority.DEFAULT, subscriber: Subscriber<T>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

fun ClientEventEmitter<*>.subscribe(priority: Int = Priority.DEFAULT, subscriber: suspend () -> Unit): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeAsFlow

fun <T : List<ClientEvent<*>>> ClientEventEmitter<T>.subscribeAsFlow(priority: Int = Priority.DEFAULT): Flow<T>

Subscribe with a flow.

subscribeChangeAsFlow

fun ClientEventEmitter<*>.subscribeChangeAsFlow(priority: Int = Priority.DEFAULT): Flow<Unit>

Subscribe with a flow.

subscribeContent

inline fun <C : EventContent> ClientEventEmitter<*>.subscribeContent(priority: Int = Priority.DEFAULT, noinline subscriber: Subscriber<ClientEvent<C>>): Unsubscriber

fun <C : EventContent> ClientEventEmitter<*>.subscribeContent(contentClass: KClass<C>, priority: Int, subscriber: Subscriber<ClientEvent<C>>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeContentAsFlow

inline fun <C : EventContent> ClientEventEmitter<*>.subscribeContentAsFlow(priority: Int = Priority.DEFAULT): Flow<ClientEvent<C>>

Subscribe events with a flow.

subscribeContentList

inline fun <C : EventContent> ClientEventEmitter<*>.subscribeContentList(priority: Int = Priority.DEFAULT, noinline subscriber: Subscriber<List<ClientEvent<C>>>): Unsubscriber

fun <C : EventContent> ClientEventEmitter<*>.subscribeContentList(contentClass: KClass<C>, priority: Int, subscriber: Subscriber<List<ClientEvent<C>>>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeContentListAsFlow

inline fun <C : EventContent> ClientEventEmitter<*>.subscribeContentListAsFlow(priority: Int = Priority.DEFAULT): Flow<List<ClientEvent<C>>>

Subscribe events with a flow.

subscribeEachEvent

fun ClientEventEmitter<*>.subscribeEachEvent(priority: Int = Priority.DEFAULT, subscriber: Subscriber<ClientEvent<*>>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeEachEventAsFlow

fun ClientEventEmitter<*>.subscribeEachEventAsFlow(priority: Int = Priority.DEFAULT): Flow<ClientEvent<*>>

Subscribe events with a flow.

subscribeEvent

inline fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEvent(priority: Int = Priority.DEFAULT, noinline subscriber: Subscriber<E>): Unsubscriber

fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEvent(contentClass: KClass<C>, eventClass: KClass<E>, priority: Int, subscriber: Subscriber<E>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeEventAsFlow

inline fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEventAsFlow(priority: Int = Priority.DEFAULT): Flow<E>

Subscribe events with a flow.

subscribeEventList

inline fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEventList(priority: Int = Priority.DEFAULT, noinline subscriber: Subscriber<List<E>>): Unsubscriber

fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEventList(contentClass: KClass<C>, eventClass: KClass<E>, priority: Int, subscriber: Subscriber<List<E>>): Unsubscriber

Subscribers have to be aware to unsubscribe when the scope of the subscriber is destroyed.

subscribeEventListAsFlow

inline fun <C : EventContent, E : ClientEvent<C>> ClientEventEmitter<*>.subscribeEventListAsFlow(priority: Int = Priority.DEFAULT): Flow<List<E>>

Subscribe events with a flow.