Отладка Kotlin Flow с помощью IntelliJ IDEA – руководство

Создание Kotlin flow

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

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

2. Для использования библиотеки kotlinx.coroutines в проекте Gradle добавьте следующую зависимость в build.gradle(.kts):

   dependencies {
       implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1")
   }
   

   dependencies {
       implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1'
   }
   

   Для других систем сборки см. инструкции в kotlinx.coroutines README.

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

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

4. Создайте функцию 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)
       }
   }
   

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

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

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

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

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

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

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

   

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

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

   

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

   

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

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

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

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

   

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

   

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

   

Оптимизированные переменные

Если вы используете функции suspend, в отладчике вы можете увидеть текст «была оптимизирована» рядом с именем переменной:

Это означает, что срок жизни переменной был уменьшен, и переменная больше не существует. Отладка кода с оптимизированными переменными затруднена, поскольку вы не видите их значения. Вы можете отключить это поведение с помощью опции компилятора -Xdebug.

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

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. Возобновите сеанс отладки, нажав Возобновить программу в окне отладки Отладка.

   

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

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