core/dev.fritz2.core/EmittingHandler

EmittingHandler

class EmittingHandler<A, E>(val collectWithChannel: (Flow<A>, FlowCollector<E>, Job) -> Unit, flow: MutableSharedFlow<E> = MutableSharedFlow()) : Handler<A> , Flow<E>

An EmittingHandler is a special Handler that constitutes a new Flow by itself. You can emit values to this Flow from your code and connect it to other Handlers on this or on other Stores. This way inter-store-communication is done in fritz2.

Parameters

collectWithChannel

defines how to handle the values of the connected Flow

Constructors

EmittingHandler

fun <A, E> EmittingHandler(collectWithChannel: (Flow<A>, FlowCollector<E>, Job) -> Unit, flow: MutableSharedFlow<E> = MutableSharedFlow())

Functions

open suspend override fun collect(collector: FlowCollector<E>)

Properties

collectWithChannel

val collectWithChannel: (Flow<A>, FlowCollector<E>, Job) -> Unit

open override val process: (Flow<A>, Job) -> Unit

function defining how this Handler collects a Flow when connected using handledBy

Extensions

val Flow<MessageEvent>.arrayBuffer: Flow<ArrayBuffer>

gives the MessageEvent.data as Flow of ArrayBuffer

val Flow<MessageEvent>.blob: Flow<Blob>

gives the MessageEvent.data as Flow of Blob

val Flow<MessageEvent>.body: Flow<String>

gives the MessageEvent.data as Flow of String

fun <E : Event> Flow<E>.composedPath(): Flow<Array<EventTarget>>

Calls Event.composedPath on the Event-flow.

val Flow<MessageEvent>.data: Flow<Any?>

gives the MessageEvent.data as Flow of Any

infix fun <A> Flow<A>.handledBy(handler: Handler<A>)

Connects a Flow to a Handler.

infix fun <A> Flow<A>.handledBy(execute: suspend (A) -> Unit): Job

Connects a Flow to a suspendable execute function.

fun <E : Event> Flow<E>.preventDefault(): Flow<E>

Calls Event.preventDefault on the Event-flow.

stopImmediatePropagation

fun <E : Event> Flow<E>.stopImmediatePropagation(): Flow<E>

Calls Event.stopImmediatePropagation on the Event-flow.

stopPropagation

fun <E : Event> Flow<E>.stopPropagation(): Flow<E>

Calls Event.stopPropagation on the Event-flow.

val <M : ValidationMessage> Flow<List<M>>.valid: Flow<Boolean>

Checks if a Flow of a List of ValidationMessages is valid.