reactivate Observable.withFilter

samuelgruetter · samuelgruetter · commit 00198acc1bc2 · 2013-11-22T21:30:58.000+01:00
diff --git a/language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala b/language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala/Observable.scala
@@ -1820,9 +1820,9 @@ trait Observable[+T]
     Observable[java.lang.Boolean](asJavaObservable.isEmpty).map(_.booleanValue())
   }
 
-  //def withFilter(p: T => Boolean): WithFilter[T] = {
-  //  new WithFilter[T](p, asJava)
-  //}
+  def withFilter(p: T => Boolean): WithFilter[T] = {
+    new WithFilter[T](p, asJavaObservable)
+  }
 
 }
 

Original file line number	Diff line number	Diff line change
`@@ -1820,9 +1820,9 @@ trait Observable[+T]`
`1820`	`1820`	`Observable[java.lang.Boolean](asJavaObservable.isEmpty).map(_.booleanValue())`
`1821`	`1821`	`}`
`1822`	`1822`
`1823`		`- //def withFilter(p: T => Boolean): WithFilter[T] = {`
`1824`		`- // new WithFilter[T](p, asJava)`
`1825`		`- //}`
	`1823`	`+ def withFilter(p: T => Boolean): WithFilter[T] = {`
	`1824`	`+ new WithFilter[T](p, asJavaObservable)`
	`1825`	`+ }`
`1826`	`1826`
`1827`	`1827`	`}`
`1828`	`1828`