rxrx.kt

override fun requestStatement(startDate: String?, endDate: String?, statementType: String, cardLastFourDigits : String?): Single<GenericResponse> {
        return localDataStore.getAccessToken().zipWith(localDataStore.getUserData(), BiFunction { t1: String, t2: DataUserData ->
            Pair(t1, t2)
        }).flatMap {
            remoteDataSource.requestStatement(startDate, endDate, statementType, cardLastFourDigits, it.first).map { entity ->
                mapper.customMapFromEntity(entity, it.second.EmailAddress)
            }
        }
    }


   @Test
    fun testRequestStatement_correctParamsPassed() {
        //arrange
        val captor = argumentCaptor<String>()
        val startDate = randomString()
        val endDate = randomString()
        val statementType = randomString()
        val cardLastFourDigits = randomString()

        whenever(localDataSourceMock.getAccessToken()).thenReturn(Single.just(randomString()))
        whenever(remoteDataSourceMock.requestStatement(any(), any(), any(), any(), any())).thenReturn(Single.just(FakeDataObjectGenerator.randomGenericResponseEntity()))
        whenever(localDataSourceMock.getUserData()).thenReturn(Single.just(dataUserDataMock))

        //act
        getBarterRepository.requestStatement(startDate,
                endDate, statementType, cardLastFourDigits).test()


        verify(remoteDataSourceMock).requestStatement(captor.capture(), captor.capture(), captor.capture(), captor.capture(), captor.capture())
        //assert
        assertEquals(startDate, captor.firstValue)
        assertEquals(endDate, captor.allValues[1])
        assertEquals(statementType, captor.allValues[2])
        assertEquals(cardLastFourDigits, captor.allValues[3])
    }

abi you dey switch thread for localDataStore .getAccessToken and localDataStore.getUserData()?