Implemented lastOrDefault

ReactiveX · Feb 28, 2013 · b1d8817 · b1d8817
1 parent 7f0c517
commit b1d8817
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/src/test/groovy/rx/lang/groovy/ObservableTests.groovy b/src/test/groovy/rx/lang/groovy/ObservableTests.groovy
@@ -233,6 +233,18 @@ def class ObservableTests {
         }
     }
 
+    @Test
+    public void testLastOrDefault() {
+        def val = Observable.toObservable("one", "two").lastOrDefault("default", { x -> x.length() == 3})
+        assertEquals("two", val)
+    }
+
+    @Test
+    public void testLastOrDefault2() {
+        def val = Observable.toObservable("one", "two").lastOrDefault("default", { x -> x.length() > 3})
+        assertEquals("default", val)
+    }
+
     def class AsyncObservable implements Func1<Observer<Integer>, Subscription> {
 
         public Subscription call(final Observer<Integer> observer) {