diff --git a/summingbird-core/src/main/scala/com/twitter/summingbird/Producer.scala b/summingbird-core/src/main/scala/com/twitter/summingbird/Producer.scala index ae1fc4bdd..b8dd9c139 100644 --- a/summingbird-core/src/main/scala/com/twitter/summingbird/Producer.scala +++ b/summingbird-core/src/main/scala/com/twitter/summingbird/Producer.scala @@ -243,6 +243,8 @@ sealed trait Producer[P <: Platform[P], +T] { self: Product => // Enforce using the OptionMapped here: optionMap(Some(_).filter(fn)) + def withFilter(fn: T => Boolean): Producer[P, T] = filter(fn) + /** * This is identical to a certain leftJoin: * map((_, ())).leftJoin(srv).mapValues{case (_, v) => v}