filter

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