Отладка Kotlin Flow с помощью IntelliJ IDEA – учебное пособие

Создание Kotlin flow

Создайте Kotlin flow с медленным эмиттером и медленным коллектором:

1. Откройте Kotlin-проект в IntelliJ IDEA. Если у вас нет проекта, создайте его.

2. Откройте файл main.kt в src/main/kotlin.

   Директория src содержит Kotlin-исходные файлы и ресурсы. Файл main.kt содержит пример кода, который будет выводить Hello World!.

3. Создайте функцию simple(), которая возвращает поток из трех чисел:

   • Используйте функцию delay() для имитации ресурсоёмкого блокирующего кода. Она приостанавливает корутину на 100 мс без блокировки потока.

   • Выводите значения в цикле for с помощью функции emit().

   import kotlinx.coroutines.*
   import kotlinx.coroutines.flow.*
   import kotlin.system.*
   
   fun simple(): Flow<Int> = flow {
       for (i in 1..3) {
           delay(100)
           emit(i)
       }
   }
   

4. Измените код в функции main():

   • Используйте блок runBlocking() для обертывания корутины.

   • Соберите выводимые значения с помощью функции collect().

   • Используйте функцию delay() для имитации ресурсоёмкого кода. Она приостанавливает корутину на 300 мс без блокировки потока.

   • Выведите собранное значение из потока с помощью функции println().

   fun main() = runBlocking {
       simple()
           .collect { value ->
               delay(300)
               println(value)
           }
   }
   

5. Соберите код, нажав Собрать проект.

   

Отладка корутины

1. Установите контрольную точку на строке, где вызывается функция emit():

   

2. Запустите код в режиме отладки, нажав Отладка рядом с настройками запуска в верхней части экрана.

   

   Открывается окно Отладки:

   • Вкладка Фреймы содержит стек вызовов.

   • Вкладка Переменные содержит переменные в текущем контексте. Она показывает, что поток выводит первое значение.

   • Вкладка Корутины содержит информацию о запущенных или приостановленных корутинах.

   

3. Возобновите сеанс отладки, нажав Продолжить программу в окне Отладки. Программа остановится на той же контрольной точке.

   

   Теперь поток выводит второе значение.

   

Добавление корутины, выполняющейся параллельно

1. Откройте файл main.kt в src/main/kotlin.

2. Улучшите код для одновременного выполнения эмиттера и коллектора:

   • Добавьте вызов функции buffer() для одновременного выполнения эмиттера и коллектора. buffer() сохраняет выводимые значения и выполняет коллектор потока в отдельной корутине.

   fun main() = runBlocking<Unit> {
       simple()
           .buffer()
           .collect { value ->
               delay(300)
               println(value)
           }
   }
   

3. Соберите код, нажав Собрать проект.

Отладка Kotlin flow с двумя корутинами

1. Установите новую контрольную точку в println(value).

2. Запустите код в режиме отладки, нажав Отладка рядом с настройками запуска в верхней части экрана.

   

   Открывается окно Отладки.

   На вкладке Корутины вы можете увидеть, что две корутины выполняются параллельно. Коллектор и эмиттер потока выполняются в отдельных корутинах из-за функции buffer(). Функция buffer() буферизует выводимые значения из потока. Корутина эмиттера имеет статус ЗАПУЩЕНА, а корутина коллектора — ПРИОСТАНОВЛЕНА.

3. Возобновите сеанс отладки, нажав Продолжить программу в окне Отладки.

   

   Теперь корутина коллектора имеет статус ЗАПУЩЕНА, а корутина эмиттера — ПРИОСТАНОВЛЕНА.

   Вы можете углубиться в каждую корутину для отладки своего кода.