Lekce 8 - Předávání dat coroutines pomocí kanálů v Kotlin

V minulé lekci, Využití Flow a Sequence u coroutines v Kotlin, jsme se seznámili s rozhraními Flow a Sequence a ukázali si, jak je můžeme ve svých aplikacích využít.

V dnešním tutoriálu zaměřeném na coroutines se naučíme pracovat s kanály, které slouží ke komunikaci mezi coroutines. Vše si opět ukážeme na praktických příkladech, kde si použití Channel vyzkoušíme.

Předávání dat coroutines pomocí Channel

Kanály umožňují jednoduché předávání objektů mezi jednotlivými coroutines. Kanál - Channel poskytuje metody send() a receive(), které umožňují poslat a přijmout data z kanálu. Při vytváření instance Channel v Kotlin je třeba určit typ dat, která budou kanálem přenášena.

Vytvoření Channel s metodami send() a receive()

Pojďme si vše ukázat nejprve na jednoduchém příkladu komunikace coroutines prostřednictvím Channel:

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

   // Coroutine pro odesílání objektů
   launch {
      repeat(3) {
          channel.send(it)
          delay(1000)
      }
   }

   // Coroutine pro přijímání objektů
   launch {
       while (isActive) {
           println(channel.receive())
       }
   }
}

Po spuštění tohoto programu dostaneme následující

...konec náhledu článku...
Pokračuj dál