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

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

Properties

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

collectWithChannel

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

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

gives the MessageEvent.data as Flow of Any

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

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

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

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

Functions

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

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

Calls Event.composedPath on the Event-flow.

open operator fun invoke(data: A)

Calls this handler exactly once.

operator fun Handler<Unit>.invoke()

Calls this handler exactly once.

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.