remove joinToString() and withIndex() tests

Author: thomasnield

src/test/kotlin/io/reactivex/rxkotlin/ExtensionTests.kt

@@ -170,15 +170,6 @@ class ExtensionTests : KotlinTests() {
         verify(a, times(0)).received(3)
     }
 
-    @Test fun testTakeWhileWithIndex() {
-        listOf(1, 2, 3).toObservable()
-                .takeWhile { x -> x < 3 }
-                .zipWith((0..Integer.MAX_VALUE).toObservable(), BiFunction { x: Int, i: Int -> x })
-                .subscribe(received())
-        verify(a, times(1)).received(1)
-        verify(a, times(1)).received(2)
-        verify(a, times(0)).received(3)
-    }
 
     @Test fun testToSortedList() {
         TestFactory().numbers.toSortedList().subscribe(received())
@@ -273,24 +264,6 @@ class ExtensionTests : KotlinTests() {
         }
     }
 
-    @Test
-    fun testJoinToString1() {
-        Observable.range(1, 5)
-                .joinToString(separator = ",")
-                .test()
-                .await()
-                .assertResult("1,2,3,4,5")
-    }
-
-    @Test
-    fun testJoinToString2() {
-        Observable.range(1, 5)
-                .joinToString(separator = ",", prefix = "(", postfix = ")")
-                .test()
-                .await()
-                .assertResult("(1,2,3,4,5)")
-    }
-
     inner class TestFactory {
         var counter = 1
 

src/test/kotlin/io/reactivex/rxkotlin/FlowableTest.kt

@@ -72,25 +72,6 @@ class FlowableTest {
         Assert.assertEquals((0..10).toList().reversed(), (-10..Integer.MAX_VALUE).toFlowable().skip(Integer.MAX_VALUE.toLong()).map { Integer.MAX_VALUE - it }.toList().blockingGet())
     }
 
-    @Test fun testWithIndex() {
-        listOf("a", "b", "c").toFlowable()
-                .withIndex()
-                .toList()
-                .test()
-                .assertValues(listOf(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c")))
-    }
-
-    @Test fun `withIndex() shouldn't share index between multiple subscribers`() {
-        val o = listOf("a", "b", "c").toFlowable().withIndex()
-
-        o.test()
-                .await()
-                .assertValues(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c"))
-
-        o.test()
-                .await()
-                .assertValues(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c"))
-    }
 
     @Test fun testFold() {
         val result = listOf(1, 2, 3).toFlowable().reduce(0) { acc, e -> acc + e }.blockingGet()

src/test/kotlin/io/reactivex/rxkotlin/ObservableTest.kt

@@ -85,30 +85,6 @@ class ObservableTest {
         assertEquals((0..10).toList().reversed(), result)
     }
 
-    @Test fun testWithIndex() {
-        listOf("a", "b", "c").toObservable()
-                .withIndex()
-                .toList()
-                .test()
-                .assertValues(listOf(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c")))
-    }
-
-    @Test fun `withIndex() shouldn't share index between multiple subscribers`() {
-        val o = listOf("a", "b", "c").toObservable().withIndex()
-
-        val subscriber1 = TestObserver.create<IndexedValue<String>>()
-        val subscriber2 = TestObserver.create<IndexedValue<String>>()
-
-        o.subscribe(subscriber1)
-        o.subscribe(subscriber2)
-
-        subscriber1.awaitTerminalEvent()
-        subscriber1.assertValues(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c"))
-
-        subscriber2.awaitTerminalEvent()
-        subscriber2.assertValues(IndexedValue(0, "a"), IndexedValue(1, "b"), IndexedValue(2, "c"))
-    }
-
     @Test fun testReduce() {
         val result = listOf(1, 2, 3).toObservable().reduce(0) { acc, e -> acc + e }.blockingGet()
         assertEquals(6, result)