mayojava

fun main() = runBlocking<Unit> {
    val channel = ConflatedBroadcastChannel<Int>()

    launch {
        channel.consumeEach {
            println("first: $it")
            delay(500)
        }
    }

mayojava

fun main() = runBlocking {
    val channel = Channel<Int>()
    launch {
        repeat(5) {
            channel.send(it*it)
        }
        channel.close()
    }

    println("begin")

mayojava

fun main() = runBlocking<Unit> {
    val channel = Channel<Int>()

    launch {
        for (i in 1..5) {
            channel.send(i)
        }
        channel.close()
    }

mayojava

val channel = Channel<ItemType>(bufferSize)

mayojava

interface SendChannel<in E> {
    public suspend fun send(element: E)
    public fun offer(element: E): Boolean
    public fun close(cause: Throwable? = null): Boolean
}

interface ReceiveChannel<out E> {
   public suspend fun receive(): E
   public fun poll(): E?
   public fun cancel()

mayojava

while (isActive) { 
    // print a message twice a second
    if (System.currentTimeMillis() >= nextPrintTime) {
        println("I'm sleeping ${i++} ...")
        nextPrintTime += 500L
    }
}

mayojava

class MainActivity: AppCompatActivity(), CoroutineScope {
    lateinit var job: Job

    override val coroutineContext: CoroutineContext
        get() = job + Dispatchers.Main

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        job = Job()
    }

mayojava

fun main() = runBlocking<Unit> {
    launchChildren()
    println("body of main")
}

suspend fun launchChildren() = supervisorScope {
    launch(Dispatchers.Default) {
        repeat(5) {
            println("coroutine 1: count $it")
            if(it == 2) {

mayojava

fun main() = runBlocking{
    launchChildren()
    println("never gets printed") // this line never gets printed 
}

suspend fun launchChildren(): Int = coroutineScope {
    val first = async {
        try {
            firstValue()
        } finally {

mayojava

fun main() = runBlocking<Unit>{
    launch {
        withContext(NonCancellable) {
            repeat(5) {
                println("count: $it")
                delay(500)
            }
        }
    }