@@ -0,0 +1,1316 @@
+/*%0D%0A * Copyright 2011-2013 David Karnok%0D%0A *%0D%0A * Licensed under the Apache License, Version 2.0 (the %22License%22);%0D%0A * you may not use this file except in compliance with the License.%0D%0A * You may obtain a copy of the License at%0D%0A *%0D%0A *     http://www.apache.org/licenses/LICENSE-2.0%0D%0A *%0D%0A * Unless required by applicable law or agreed to in writing, software%0D%0A * distributed under the License is distributed on an %22AS IS%22 BASIS,%0D%0A * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.%0D%0A * See the License for the specific language governing permissions and%0D%0A * limitations under the License.%0D%0A */%0D%0Apackage hu.akarnokd.reactive4java.test;%0D%0A%0D%0Aimport hu.akarnokd.reactive4java.base.Observable;%0D%0Aimport hu.akarnokd.reactive4java.interactive.Interactive;%0D%0Aimport hu.akarnokd.reactive4java.reactive.Reactive;%0D%0A%0D%0Aimport org.junit.Test;%0D%0A%0D%0A/**%0D%0A * Test the Reactive.repeat behavior.%0D%0A * @author akarnokd, 2013.11.24.%0D%0A */%0D%0Apublic class TestReactiveRepeat %7B%0D%0A%09/** Test the early termination of repeat through take. */%0D%0A%09@Test(timeout = 1000)%0D%0A%09public void testTakeSome() %7B%0D%0A%09%09Observable%3CInteger%3E source = Reactive.take(Reactive.repeat(%0D%0A%09%09%09%09Reactive.singleton(1), Integer.MAX_VALUE), 100);%0D%0A%09%09%0D%0A%09%09Iterable%3CInteger%3E expected = Interactive.repeat(1, 100);%0D%0A%09%09TestUtil.assertEqual(expected, source);%0D%0A%09%7D%0D%0A%0D%0A%7D%0D%0A

Test case from RxJava pull #498