From 8caa1319341d7bcfa5bc5a900dd21de60724618d Mon Sep 17 00:00:00 2001 From: Eoin Coffey Date: Tue, 22 May 2018 15:38:32 -0600 Subject: [PATCH] Producer: adds `withFilter` to support scala 2.12 for-comprehensions --- .../src/main/scala/com/twitter/summingbird/Producer.scala | 2 ++ 1 file changed, 2 insertions(+) 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}