Для чего используются стримы во Flutter?

Стримы во Flutter используются для обработки последовательности асинхронных событий.

Основные случаи применения:

1. Реагирование на изменения данных: Redux, BLoC-паттерны используют стримы для управления состоянием приложения и реактивного обновления UI при изменениях.
2. Работа с потоковыми данными: Получение данных по сети (например, WebSocket), чтение из файлов, работа с сенсорами устройства.
3. Обработка пользовательских взаимодействий: Отслеживание скроллинга, Draggable / DragTarget.
4. Асинхронные операции: Выполнение задач в фоновом режиме и получение результатов по мере их готовности.

Ключевые понятия:

• Stream: Последовательность асинхронных событий. Стрим может эмитировать 0 или более событий, а затем завершиться (с успехом или ошибкой).
• StreamSubscription: Представляет подписку на стрим. Позволяет получать события из стрима и управлять подпиской (приостанавливать, возобновлять, отменять).
• Sink: Используется для добавления данных в стрим.
• StreamBuilder: Виджет, который перестраивается при получении новых данных из стрима.

// Пример использования StreamBuilder
StreamBuilder<int>(
  stream: counterStream, // Ваш стрим
  builder: (BuildContext context, AsyncSnapshot<int> snapshot) {
    if (snapshot.hasError) {
      return Text('Ошибка: ${snapshot.error}');
    }
    switch (snapshot.connectionState) {
      case ConnectionState.none:
        return Text('Ожидание...');
      case ConnectionState.waiting:
        return CircularProgressIndicator();
      case ConnectionState.active:
        return Text('Значение: ${snapshot.data}');
      case ConnectionState.done:
        return Text('Стрим завершен. Последнее значение: ${snapshot.data}');
    }
  },
)

// Пример простого стрима, который эмитирует числа
Stream<int> countStream(int max) async* {
  for (int i = 0; i <= max; i++) {
    await Future.delayed(Duration(seconds: 1));
    yield i; // Эмиттируем значение
  }
}