sharedflow

collect

collect

cancel

pollingScope

send

exception

@ExperimentalCoroutinesApi
    fun poll(scope: CoroutineScope) = callbackFlow {
        invokeOnClose { Timber.e("Debug: channel closed") }
        while (true) {
            try {
                val nextInt = Random.nextInt(0, 100)
                Timber.e("Debug: nextInt -> $nextInt")
                send(nextInt)
                delay(MIN_REFRESH_TIME_MS)
            } catch (throwable: Throwable) {
                Timber.e("Debug: error -> ${throwable.message}")
            }
        }
    }.shareIn(scope = scope, replay = 1, started = SharingStarted.WhileSubscribed())

pollingScope.launch {
                engine.poll(applicationScope).collect {
                    Timber.e("Debug: collect 1 -> $it")
                }
            }
            pollingScope.launch {
                engine.poll(applicationScope).collect {
                    Timber.e("Debug: collect 2 -> $it")
                }
            }
            pollingScope.launch {
                engine.poll(randomScope).collect {
                    Timber.e("Debug: collect 3 -> $it")
                }
            }

$poll: Debug: nextInt -> 59
$poll: Debug: nextInt -> 68
$poll: Debug: nextInt -> 73
$poll$3$invokeSuspend$$inlined$collect: Debug: collect 2 -> 73
$poll$2$invokeSuspend$$inlined$collect: Debug: collect 1 -> 59
$poll$4$invokeSuspend$$inlined$collect: Debug: collect 3 -> 68

lateinit var

val

late init var foo: Bar()

fun goTime() {
   foo = Bar()
   println(foo)
}

var foo: Bar? = null

fun goTime() {
   val foo = foo ?: Bar()
   println(foo)
}

fun parseIntEither(s: String): Either<NumberFormatException, Int> =
        if (s.matches(Regex("-?[0-9]+"))) Either.Right(s.toInt())
        else Either.Left(NumberFormatException("$s is not a valid integer."))

    val list = listOf("1", "2", "3").k().traverse(Either.applicative(), ::parseIntEither)
    val failFastList = listOf("1", "abc", "3", "4s").k().traverse(Either.applicative(), ::parseIntEither)

red line under Either.applicative(), 
Cannot inline bytecode built with JVM target 1.8 into bytecode that is being built with JVM target 1.6
I can't find a solution on IDEA, but it's ok on Android Studio, and IDEA using the same JDK 1.8 from Android Studio

const

class Foo

class Bar(
    private val foo: Foo
) {

    override fun equals(other: Any?): Boolean {
        if(other !is Bar) return false
        return this.foo == other.foo // it works?
    }

    override fun hashCode(): Int {
        return foo.hashCode()
    }
}

fun test() {
    val foo = Foo()
    val bar = Bar(foo)
    val test = bar.foo // private, cannot access
}

T

with

T

JsonObject

@JvmInline
value class MyJson(val json: JsonObject) {
  inline val type
    get() = with(json.jsonObject("type") {
        string("actual_type") // this crashes at runtime because it is looking for this field in the json property instead of the one from the with scope
    }
}

io.github.gradle-nexus.publish-plugin

from(components["java"])

fold

reduce

var acc = sim.outputRange.indices
        val tree = sortedSetOf<Int>()
        while (acc.isNotEmpty()) {
            tree += acc;
              acc = acc.map { this.usefulScope(it) }.flatten().filter {
                it in sim.hiddenRange } - tree
        }

class Example(val id: Int) {
    companion object {
        fun <T, V> demo(property: KProperty1<T, V>, value: V): V? {
            return null
        }
    }
}

// this works
val test1 = Example.demo(Example::id, 0)

// this works, but shouldn't pass validation
val test2 = Example.demo(Example::id, "1")

Int