arkivanov

internal class TestKittenDataSource(
    private val scheduler: TestScheduler
) : KittenDataSource {
    private var images by AtomicReference<List<String>?>(null)
    private var seed by AtomicInt()

    override fun load(limit: Int, page: Int): Maybe<String> =
        singleFromFunction { images }
            .notNull()
            .map {

arkivanov

internal class KittenComponent internal constructor(dataSource: KittenDataSource) {
    constructor() : this(KittenDataSource())

    fun onViewCreated(view: KittenView) { /* ... */ }

    fun onStart() { /* ... */ }

    fun onStop() { /* ... */ }

    fun onViewDestroyed() { /* ... */ }

arkivanov

@Test
fun isLoading_true_WHEN_loading() {
    networkScheduler.isManualProcessing = true
    network.generateImages()

    val store = store()

    assertTrue(store.state.isLoading)
}

arkivanov

@Test
fun reloads_images_WHEN_Intent_Reload() {
    network.generateImages()
    val store = store()
    val newImages = network.generateImages()

    store.onNext(Intent.Reload)

    assertEquals(State.Data.Images(urls = newImages), store.state.data)
}

arkivanov

@Test
fun loads_images_WHEN_created() {
    val images = network.generateImages()

    val store = store()

    assertEquals(State.Data.Images(urls = images), store.state.data)
}

arkivanov

class KittenStoreTest {
    private val network = TestKittenStoreNetwork()
    private val parser = TestKittenStoreParser()

    private fun store(): KittenStore = KittenStoreImpl(network, parser)

    @BeforeTest
    fun before() {
        overrideSchedulers(main = { TestScheduler() })
    }

arkivanov

class KittenStoreTest {
    private val parser = TestKittenStoreParser()
    private val networkScheduler = TestScheduler()
    private val network = TestKittenStoreNetwork(networkScheduler)

    private fun store(): KittenStore = KittenStoreImpl(network, parser)

    // ...
}

arkivanov

class TestKittenStoreParser : KittenStoreImpl.Parser {
    override fun parse(json: String): Maybe<List<String>> =
        json
            .toSingle()
            .filter { it != "" }
            .map { it.split(SEPARATOR) }
            .observeOn(TestScheduler())

    private companion object {
        private const val SEPARATOR = ";"

arkivanov

interface Parser {
    fun parse(json: String): Maybe<List<String>>
}

arkivanov

class TestKittenStoreNetwork(
    private val scheduler: TestScheduler
) : KittenStoreImpl.Network {
    var images: List<String>? by AtomicReference<List<String>?>(null)
    private var seed: Int by AtomicInt()

    override fun load(): Maybe<String> =
        singleFromFunction { images }
            .notNull()
            .map { it.joinToString(separator = SEPARATOR) }