mobiuskt-extras/kt.mobius.extras/filter

filter

fun <I, O> Connectable<I, O>.filter(predicate: (I) -> Boolean): Connectable<I, O>