Что хотят услышать интервьюеры:

В Dart потоковая обработка данных строится на Stream и StreamController: данные приходят асинхронно, а подписчик обрабатывает их по мере поступления. Такой подход удобен для событий, сетевых ответов, чтения файлов и любых последовательностей значений во времени. Важно понимать разницу между одиночным событием и последовательностью событий, а также уметь подписываться и отменять подписку.

Определение:

Потоковая обработка данных в Dart — это способ работы с асинхронными последовательностями событий через Stream. В отличие от Future, который возвращает один результат, Stream может отдавать много значений по мере их появления. Для получения данных используется подписка через listen, а для создания потока — Stream, StreamController или готовые источники, например, события UI или ответы API.

Пример использования:

Например, можно получать обновления каждые секунду и обрабатывать их по мере прихода.

import 'dart:async';

void main() {
  final controller = StreamController<int>();

  controller.stream.listen(
    (value) => print('Получено: $value'),
    onDone: () => print('Поток завершён'),
  );

  controller.add(1);
  controller.add(2);
  controller.add(3);
  controller.close();
}

Пояснение кода:

Код показывает базовую схему работы с потоком.

Создаётся StreamController<int>, который позволяет вручную отправлять значения в поток.
Через controller.stream.listen(...) подписчик начинает получать события.
Каждый вызов controller.add(...) отправляет новое значение подписчику.
Когда данные закончились, вызывается controller.close(), и поток завершается.
Колбэк onDone срабатывает после закрытия потока.

Ключевые моменты:

Stream подходит для множества событий, Future — для одного результата.
Подписка на поток выполняется через listen.
Потоки могут быть холодными и горячими, в зависимости от источника данных и момента начала подписки.
Поток нужно корректно закрывать, если он создаётся вручную через StreamController.
Для удобной обработки часто используют async*, await for, map, where, transform.
В Flutter потоки часто применяются для UI-событий, WebSocket, Firebase и реактивного обновления интерфейса.

Каким образом применяется потоковая обработка данных в Dart?