FilterEffectHandler

class FilterEffectHandler<I, O>(effectHandler: Connectable<I, O>, predicate: (I) -> Boolean) : Connectable<I, O>

Creates a Connectable that delegates to effectHandler and filters I values if the predicate returns true.

Constructors

constructor(effectHandler: Connectable<I, O>, predicate: (I) -> Boolean)

open override fun connect(output: Consumer<O>): Connection<I>

inline fun <I, O, II, OO> Connectable<II, OO>.mapped(noinline mapEffect: (I) -> II? = { it as? II }, noinline mapEvent: (OO) -> O? = { it as? O }): Connectable<I, O>