arkivanov

internal class KittenDataSourceImpl : KittenDataSource {
    override fun load(limit: Int, offset: Int): Maybe<String> =
        maybeFromFunction {
            val url = URL(makeKittenEndpointUrl(limit = limit, offset = offset))
            val connection = url.openConnection() as HttpURLConnection

            connection
                .inputStream
                .bufferedReader()
                .use(BufferedReader::readText)

arkivanov

internal actual fun KittenDataSource(): KittenDataSource = KittenDataSourceImpl()

arkivanov

internal class KittenDataSourceImpl : KittenDataSource {
    override fun load(limit: Int, offset: Int): Maybe<String> =
        maybe<String> { emitter ->
            val callback: (NSData?, NSURLResponse?, NSError?) -> Unit =
                { data: NSData?, _, error: NSError? ->
                    if (data != null) {
                        emitter.onSuccess(NSString.create(data, NSUTF8StringEncoding).toString())
                    } else {
                        emitter.onComplete()
                    }

arkivanov

class DetailsFragment(output: (Output) -> Unit): Fragment() {

    sealed class Output {
        object CloseClicked : Output()
    }
}

arkivanov

package com

import kotlin.random.Random
import kotlin.time.ExperimentalTime
import kotlin.time.measureTime

private const val count = 10000000

var counter = 0

arkivanov

package com

import kotlin.random.Random
import kotlin.time.ExperimentalTime
import kotlin.time.measureTime

private const val count = 10000

@ExperimentalTime
fun main() {

arkivanov

typealias Reducer<State, Effect> = (State, Effect) -> State

arkivanov

class KittenComponent {
    private val store =
        KittenStoreImpl(
            network = KittenStoreNetwork(dataSource = KittenDataSource()),
            parser = KittenStoreParser
        )

    private var view: KittenView? = null
    private var startStopScope: DisposableScope? = null

arkivanov

class KittenComponent {

    fun onViewCreated(view: KittenView) {
    }

    fun onStart() {
    }

    fun onStop() {
    }

arkivanov

internal fun Event.toIntent(): Intent =
    when (this) {
        is Event.RefreshTriggered -> Intent.Reload
    }